#_author:来童星#date:2019/12/17#通过队列实现进程间的通信from multiprocessing import Poolimport osimport timedef 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
时间: 2024-10-08 09:30:49