主进程中等待进程池中所有任务都执行完毕

code

from multiprocessing import Pool
import time,random,os
 
def work(n):
    time.sleep(1)
    return n**2
if __name__ == '__main__':
    p=Pool()
 
    res_l=[]
    for i in range(10):
        res=p.apply_async(work,args=(i,))
        res_l.append(res)
 
    p.close()
    p.join() #等待进程池中所有进程执行完毕
 
    nums=[]
    for res in res_l:
        nums.append(res.get()) #拿到所有结果
    print(nums) #主进程拿到所有的处理结果,可以在主进程中进行统一进行处理

Outputs

macname@MacdeMacBook-Pro py % python3 cccccc.py
[0, 1, 4, 9, 16, 25, 36, 49, 64, 81]
macname@MacdeMacBook-Pro py %