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

标签：fun   ==   执行   func   进程   请求   队列实现   关闭进程   ssi   

#_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(‘所有子进程结束‘)

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

标签：fun   ==   执行   func   进程   请求   队列实现   关闭进程   ssi   

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