进程池

import os
import time
from multiprocessing import Pool

def func(i):
print('start func%s'%i,os.getpid())
time.sleep(1)
print('end func%s' % i, os.getpid())
if __name__ == '__main__':
p = Pool(3)
for i in range(10):
# p.apply(func,args=(i,)) # 同步的
p.apply_async(func,args=(i,)) # 异步的

p.close() # 结束进程池接受任务
p.join() # 感知进程池中的任务执行结束
原文地址:https://www.cnblogs.com/bozhengheng/p/10304172.html