python中进程池Pool怎么初始化

本文小编为大家详细介绍“python中进程池Pool怎么初始化”，内容详细，步骤清晰，细节处理妥当，希望这篇“python中进程池Pool怎么初始化”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。

网站建设哪家好，找创新互联公司！专注于网页设计、网站建设、微信开发、微信小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了永福免费建站欢迎大家使用！

说明

1、初始化Pool时，可以指定流程数。

2、当新请求提交到Pool时，如果池未满，则创建新流程以执行该请求。

3、如果池中的流程数达到指定的值，则等待该请求，直到池中的流程结束为止，以之前的流程执行新的任务。

实例

# -*- coding:utf-8 -*-
import os, time, random
from multiprocessing import Pool
 
 
def worker(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))
 
    
def main():
    po = Pool(3)  # 定义一个进程池，进程数3
    for i in range(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怎么初始化”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注创新互联行业资讯频道。