- #!/usr/bin/env python3
- #coding=utf-8
-
- from time import time
- import threading
- #列表长度觉得开启线程数量
- loops = ['1.txt','2.txt']
-
- #派生Thread的子类
- class threadFunc(threading.Thread):
- def __init__(self,func,args,name=''):
- threading.Thread.__init__(self)
- self.func = func
- self.args = args
- self.name = name
- def run(self):
- self.func(*self.args)
-
- def loop(name):
- with open(name,'r') as f:
- for line in f:
- if '\n' in line:
- print (name,' :',line,end='')
- else:
- print (name,' :',line)
-
- def main():
- print('starting at:',time())
- #线程锁
- threadkey = []
- nloops = range(len(loops))
-
- for i in nloops:
- #get线程锁
- #创建子类的实例
- t = threadFunc(loop,(loops[i],),loop.__name__)
- threadkey.append(t)
-
- #开启线程
- for i in nloops:
- threadkey[i].start()
- #等待所有线程结束
- for i in nloops:
- threadkey[i].join()
-
- print('All Done at:',time())
-
- if __name__ == '__main__':
- main()
复制代码
- starting at: 1590562220.892479
- 1.txt : 1005495524----a111111
- 1.txt : 1005495524----abc123
- 2.txt : 1111qqqq1111---a111111
- 1.txt : 1005495524----aini1314
- 2.txt : 1111qqqq1111---abc123
- 1.txt : 1005495524----iloveyou
- 2.txt : 1111qqqq1111---aini1314
- 1.txt : 1005495524----q1w2e3r4
- 2.txt : 111qqq111---a111111
- 1.txt : 1005495524----qq123123
- 2.txt : 111qqq111---abc123
- 2.txt : 111qqq111---aini1314
- All Done at: 1590562220.892479
-
- 请按任意键继续. . .
复制代码
|