天天看點

建立程序池

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)
           

如果程序池中的任務有異常,他不會列印出來。