通过队列实现进程间的通信(使用阻塞方式调用func函数)

#_author:来童星
#date:2019/12/17
#通过队列实现进程间的通信
from multiprocessing import Pool
import os
import time
def func(name):
print('子进程(%s)执行func %s...'%(os.getpid(),name))
time.sleep(1)
if __name__=='__main__':
print('父进程(%s)'%os.getpid())
p=Pool(3)# 定义一个进程池,最大进程数为3
for i in range(10):
p.apply(func,args=(i,))# 使用阻塞方式调用func函数
print('等待所有子进程结束')
p.close()# 关闭进程池,关闭后p不再接受新的请求
p.join()# 等待子进程结束
print('所有子进程结束')



原文地址:https://www.cnblogs.com/startl/p/12054124.html