进程池（同步和异步）

Posted 2020-11-24 liuxjie

进程池

 1 import multiprocessing
 2 import time
 3 
 4 
 5 def copy_work():
 6     print("the copy is already")
 7     time.sleep(0.5)
 8 
 9 if __name__ == ‘__main__‘:
10     # 创建一个进程池
11     pool = multiprocessing.Pool(3)
12     for i in range(10):
13 
14         # 进程池同步方式拷贝文件
15         # pool.apply(copy_work)
16         # 进程池异步拷贝文件
17         pool.apply_async(copy_work)
18     """
19     只有异步方式才需要以下两步 
20     pool.close()   #表示不再接受新的任务
21     pool.join()     #让主进程等待进程池执行接收后再退出
22     
23     """
24     pool.close()   #表示不再接受新的任务
25     pool.join()     #让主进程等待进程池执行接收后再退出