通过队列实现进程间的通信

Posted 2021-03-22 startl

#_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_async(func,args=(i,))# 使用非阻塞方式调用func函数
    print(‘等待所有子进程结束‘)
    p.close()# 关闭进程池，关闭后p不再接受新的请求
    p.join()# 等待子进程结束
    print(‘所有子进程结束‘)