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

首页 » 线/进程 » 多线程统计大量小文件的行数

准备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))

 

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

分享到:
赞(0) 打赏

评论 2

评论前必须登录!

 

  1. #1

    good厉害了

    靓妹6个月前 (03-27)
  2. #2

    奥利给

    小白6个月前 (03-28)

觉得文章有用就打赏一下弟弟吧

支付宝扫一扫打赏

微信扫一扫打赏

Vieu4.5主题
专业打造轻量级个人企业风格博客主题!专注于前端开发,全站响应式布局自适应模板。
正在播放:

作者想对您说:

累了就停下来听首歌吧

听完后会给您一个好心情

最后

等到您不容易

还希望您能多待一会儿

      00:00/00:00