Python 多线程不加锁分块读取文件的方法
程序员文章站
2022-04-29 17:39:00
多线程读取或写入,一般会涉及到同步的问题,否则产生的结果是无法预期的。那么在读取一个文件的时候,我们可以通过加锁,但读不像写操作,会导致文件错误,另外锁操作是有一定的耗时。...
多线程读取或写入,一般会涉及到同步的问题,否则产生的结果是无法预期的。那么在读取一个文件的时候,我们可以通过加锁,但读不像写操作,会导致文件错误,另外锁操作是有一定的耗时。因此通过文件分块,可以比较有效的解决多线程读问题,之前看到有人写的分块操作,比较复杂,需要实现建立好线程以及所读取块信息,在这里,我提供了一种比较简便的方法,以供参考。
#!/user/bin/env python #_*_coding:utf-8_*_ from threading import thread import time from processing import process, queue from multiprocessing import process file_path = 't' fd = open(file_path, 'r') def deal(thread_num): i = 1 line_list = [] #20是我的文件行数,正式情况下可以通过wc -l t获取 while i <= 20/thread_num: line_list.append(fd.readline()) i += 1 return line_list def todo(thread_name, line_list): # print 'thread_name:',thread_name,'start' for line in line_list: print str(thread_name) + ' counsume:' + line # print 'thread_name:', thread_name, 'end' if __name__ == '__main__': thread_num = 10 thread_list = [] for i in range(thread_num): line_list = deal(thread_num) t = thread(target=todo, args=[i, line_list]) t.start() thread_list.append(t) for t in thread_list: t.join()
下面是文件格式:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
运行的结果如下:
以上这篇python 多线程不加锁分块读取文件的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
推荐阅读
-
Python读取txt文件数据的方法(用于接口自动化参数化数据)
-
python 读取dicom文件,生成info.txt和raw文件的方法
-
python使用xlrd模块读取xlsx文件中的ip方法
-
python读取json文件并将数据插入到mongodb的方法
-
Python解析并读取PDF文件内容的方法
-
对Python多线程读写文件加锁的实例详解
-
python+opencv 读取文件夹下的所有图像并批量保存ROI的方法
-
python opencv 读取本地视频文件 修改ffmpeg的方法
-
python 读取文件并把矩阵转成numpy的两种方法
-
对Python 多线程统计所有csv文件的行数方法详解