Python多进程浏览文件夹

Gin_Q

1. #!/usr/bin/env python3
   
2. #coding:utf-8
   
3. 
   
4. import multiprocessing as multi
   
5. import os
   
6. 
   
7. class thr(multi.Process):
   
8.     def __init__(self,folder):
   
9.         multi.Process.__init__(self)
   
10.         self.folder = folder
    
11.    
    
12.     def run(self):
    
13.         for root,dirs,files in os.walk(self.folder.get()):
    
14.             print('父目录：',root)
    
15.             print('文件夹：',dirs)
    
16.             for f in files:
    
17.                 print(f)
    
18.         self.folder.task_done()
    
19. 
    
20. def Process_pool(q):
    
21.     th = thr(q)
    
22.     th.daemon = True
    
23.     th.start()   
    
24. 
    
25. if __name__ == '__main__':
    
26.     q = multi.JoinableQueue()#队列
    
27.    
    
28.     #进程池
    
29.     Process_pool(q)
    
30.     Process_pool(q)
    
31.    
    
32.     folder = [r'D:\GIN\c',r'D:\GIN\py']
    
33.     for i in range(len(folder)):
    
34.         q.put(folder[i])
    
35.    
    
36.     q.join()#等待队列清空
    

复制代码