位置: IT常识 - 正文

Python中的进程池是什么(python 进程管理)

编辑：rootadmin

推荐整理分享Python中的进程池是什么(python 进程管理)，希望有所帮助，仅作参考，欢迎阅读内容。

文章相关热门搜索词:python 进程池队列,进程池 python,python进程池的作用,python进程池和线程池,python进程池的作用,进程 python,python3 进程池,进程 python,内容如对您有帮助，希望把文章链接给更多的朋友！

进程池Pool

当需要创建的子进程数量不多时，可以直接利用multiprocessing中的Process动态成生多个进程，但如果是上百甚至上千个目标，手动的去创建进程的工作量巨大，此时就可以用到multiprocessing模块提供的Pool方法。

初始化Pool时，可以指定一个进程数，当有新的请求提交到Pool中时，如果池还没有满，那么就会创建一个新的进程用来执行该请求；但如果池中的进程数已经达到指定的值，那么该请求就会等待，直到池中有进程结束，才会创建新的进程来执行。

frommultiprocessingimportPoolimportosimporttimeimportrandomdefworker(msg):t_start=time.time()print("%d进程开始执行%d"%(os.getpid(),msg))#random.random()随机生成0~1之间的浮点数time.sleep(random.random()*2)t_stop=time.time()print(msg,"执行完毕，耗时%0.2f"%(t_stop-t_start))if__name__=='__main__':po=Pool(3)#定义一个进程池，进程数3foriinrange(0,10):#Pool.apply_async(要调用的目标,(传递给目标的参数元祖,))#每次循环将会用空闲出来的子进程去调用目标po.apply_async(worker,(i,))print("----start----")po.close()#关闭进程池，关闭后po不再接收新的请求po.join()#等待po中所有子进程执行完成，必须放在close语句之后print("-----end-----")

运行结果为：

----start----4353进程开始执行04354进程开始执行14355进程开始执行22,执行完毕，耗时0.204355进程开始执行31,执行完毕，耗时1.194354进程开始执行44,执行完毕，耗时0.374354进程开始执行50,执行完毕，耗时1.574353进程开始执行65,执行完毕，耗时0.194354进程开始执行73,执行完毕，耗时1.634355进程开始执行86,执行完毕，耗时0.494353进程开始执行98,执行完毕，耗时0.757,执行完毕，耗时0.909,执行完毕，耗时0.63-----end-----

相关推荐：《Python视频教程》

multiprocessing.Pool常用函数解析：

apply_async(func[, args[, kwds]]) ：使用非阻塞方式调用func（并行执行，堵塞方式必须等待上一个进程退出才能执行下一个进程），args为传递给func的参数列表，kwds为传递给func的关键字参数列表；

apply(func[, args[, kwds]])：使用阻塞方式调用func

close()：关闭Pool，使其不再接受新的任务；

terminate()：不管任务是否完成，立即终止；

join()：主进程阻塞，等待子进程的退出，必须在close或terminate之后使用；

apply堵塞式

frommultiprocessingimportPoolimportosimporttimeimportrandomdefworker(msg):t_start=time.time()print("%d进程开始执行%d"%(os.getpid(),msg))#random.random()随机生成0~1之间的浮点数time.sleep(random.random()*2)t_stop=time.time()print(msg,"执行完毕，耗时%0.2f"%(t_stop-t_start))if__name__=='__main__':po=Pool(3)#定义一个进程池，进程数3foriinrange(0,10):#Pool.apply_async(要调用的目标,(传递给目标的参数元祖,))#每次循环将会用空闲出来的子进程去调用目标po.apply(worker,(i,))print("----start----")po.close()#关闭进程池，关闭后po不再接收新的请求po.join()#等待po中所有子进程执行完成，必须放在close语句之后print("-----end-----")

运行结果为：

4400进程开始执行00,执行完毕，耗时1.894401进程开始执行11,执行完毕，耗时1.914402进程开始执行22,执行完毕，耗时1.644400进程开始执行33,执行完毕，耗时1.164401进程开始执行44,执行完毕，耗时1.854402进程开始执行55,执行完毕，耗时0.294400进程开始执行66,执行完毕，耗时0.194401进程开始执行77,执行完毕，耗时1.194402进程开始执行88,执行完毕，耗时0.614400进程开始执行99,执行完毕，耗时1.08----start---------end-----