多进程浏览文件夹

Cool_Breeze

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()):#返回self.folder中的一个元素
    
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()#等待队列清空
    

复制代码

win_233

没有注释吗

Cool_Breeze

win_233 发表于 2020-6-3 16:38
没有注释吗

有的！