多进程浏览文件夹

Cool_Breeze

#!/usr/bin/env python3
#coding:utf-8

import multiprocessing as multi
import os

class thr(multi.Process):
    def __init__(self,folder):
        multi.Process.__init__(self)
        self.folder = folder
    
    def run(self):
        for root,dirs,files in os.walk(self.folder.get()):#返回self.folder中的一个元素
            print('父目录：',root)
            print('文件夹：',dirs)
            for f in files:
                print(f)
        self.folder.task_done()

def Process_pool(q):
    th = thr(q)
    th.daemon = True #主进程结束等待子进程结束
    th.start()    

if __name__ == '__main__':
    q = multi.JoinableQueue()#队列
    
    #进程池
    Process_pool(q)
    Process_pool(q)
    
    folder = [r'D:\GIN\c',r'D:\GIN\py'] #文件夹列表
    for i in range(len(folder)):
        q.put(folder[i]) #将元素放入队列
    
    q.join()#等待队列清空

win_233

没有注释吗

Cool_Breeze

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

有的！