说明
1、当Pool初始化时,可以指定流程数。
2、当新请求提交到Pool时,如果池未满,则创建新流程执行该请求。
3、如果池中的流程数达到指定值,则等待要求,直到池中的流程结束,以前的流程执行新的任务。
实例
#-*-coding:utf-8-*- importos,time,random frommultiprocessingimportPool defworker(msg): t_start=time.time() print("%s开始执行,过程号为%d"%(msg,os.getpid())) #random.random()在0~1之间随机生成浮点数 time.sleep(random.random()*2) t_stop=time.time() print(msg,"执行完毕,耗时%0.2f\n"%(t_stop-t_start)) defmain(): po=Pool(3)#定义一个进程池,进程数为3 foriinrange(0,10): #Pool().apply_async(要调用的目标,(传递给目标参数元祖,)) #每个循环都将使用空闲的子过程来调用目标 po.apply_async(worker,(i,)) print("----start----") po.close()#关闭进程池,PO关闭后不会收到新的请求 po.join()#等待po中所有子过程的完成,Close语句后必须放置 print("-----end-----") if__name__=="__main__": main()
以上是Python中进程池Pool的初始化,希望对大家有所帮助。学习更多的编程基础知识:python学习网
本文教程操作环境:windows7系统Python 3.9.1,DELL G3电脑。