多线程统计大量小文件的行数

2020-02-10 145次浏览 已收录 2个评论

准备40个文件,开启40个线程。

import threading
import time
count=0;
class go(threading.Thread):
    def __init__(self,index):
        threading.Thread.__init__(self)
        self.index=index#每个线程要跑的文件索引
    def run(self):
        global count
        fh=open("/Users/new/lean/test/docter/线程作业/ip "+str(self.index)+".txt")
        for line in fh:
            count+=1
            # print(self.index,"正在记数....")
        fh.close()
start=time.time()
a=[]
for i in range(1,41):
    x=go(i)
    x.start()
    a.append(x)
for j in a:#主线程等待子线程
    j.join()
over=time.time()
print("总共:"+str(count)+"\n耗时%f"%(over-start))

 


渣渣龙, 版权所有丨如未注明 , 均为原创丨本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:多线程统计大量小文件的行数
喜欢 (0)

您必须 登录 才能发表评论!

(2)个小伙伴在吐槽
  1. good厉害了
    靓妹2020-03-27 13:18
  2. 奥利给
    小白2020-03-28 16:59