天天看点

创建进程池

import multiprocessing
import os

def copy_file(file_name):

    file_names = os.listdir(old_folder_name)
    po = multiprocessing.Pool(5) # 创建进程池
    for file_name in file_names: # 向进程池中添加copy文件的任务
    po.apply_async(copy_file, args=(file_name,))
    po.close()
    po.join

if __name__ == "__main__"
    copy_file(file_name)
           

如果进程池中的任务有异常,他不会打印出来。