位置: 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视频教程》

Python中的进程池是什么(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-----

说明:通过运行结果可以看出来,阻塞式会等进程池中的进程都执行完毕了才会运行主进程的start和end的打印

相关推荐:

本文链接地址:https://www.jiuchutong.com/zhishi/310240.html 转载请保留说明!

上一篇:帝国cms怎么换模板(帝国cms移动端设置教程)

下一篇:php中__get如何获取成员属性(php __get())

  • 出口发票开错了如何处理
  • 本月发生费用未支付会计处理
  • 财务台账包含什么
  • 形式发票需要签字盖章吗
  • 国家对小微企业扶持有哪些政策
  • 公积金做账需要计提吗怎么做
  • 代扣代缴增值税纳税义务发生时间
  • 购买了材料怎么做账
  • 单位发放奖金如何做账
  • 丢失增值税发票最新处理办法
  • 普通发票作废怎么验旧
  • 公司收到法院的欠款起诉书,应该怎么办
  • 注销时公司账上没有钱付股东投资款
  • 小规模纳税人网上申报税务操作流程
  • 收到多开发票已认证怎么做账?
  • 外籍人士享受满五唯一吗
  • 公司取得政府赔偿款要交增值税吗
  • 清算时土地增值税计税依据
  • 所得税的计税依据
  • 预付账款讲解
  • 预收账款期末余额在贷方
  • 进口原材料的关税怎么算
  • 专利技术使用权转让属于特许权使用费
  • 车辆购置税计入固定资产一起折旧吗
  • 如何理解总分机的概念
  • 出口企业出口退税
  • 总账每个月都要结账吗
  • 报纸公示具有什么法律效应
  • 以土地入股房开什么发票
  • 营改增后销售不动产税率变化时间
  • php数组函数,选班长
  • safari浏览器怎么快进
  • php 静态
  • 电商第三方平台规则的特点
  • dcom进程
  • 常用的php操作mysql的函数有哪些
  • 分批次付款
  • php jsondecode
  • vue2.
  • tf fans club
  • 微信小程序实训内容
  • topas命令详解
  • 原材料暂估入库成本结转处理
  • 资产总额不超过5000万是指全年平均收入吗
  • 超过认证期限的发票未抵扣能红冲吗
  • 个体工商户纳税申抿
  • 企业所得税期间费用明细表
  • 可以直接申请一个微信吗
  • 会计上视同销售的八种情况是哪些?
  • 汇算清缴纳税调整需要做账吗
  • 进项认证以后如何处理
  • 可明确区分的商品什么意思
  • 小规模纳税人开专票税率是1%还是3%
  • 收到法院退回的诉讼费怎么做账
  • 房租费用计入什么现金流量
  • 调整期初库存商品分录
  • 如何进行税前扣除
  • 关于发票丢失的处罚
  • 小企业建账选哪种会计制度
  • nvidia专业卡性能对比
  • Mac苹果系统怎么转换中文
  • ps到底怎么用
  • win8 休眠
  • Win10无法获取ipv4
  • python中的json
  • cocos lua js
  • dos 批处理
  • 浅析中国式现代化的理论价值与现实意义
  • javascript判断语句
  • html手机号验证
  • unity gui教程
  • nodejs实战
  • python数字运算规则
  • unity控制组件开关
  • 查找的算法有哪些
  • python发送信息到微信
  • 增值税0申报操作流程
  • 百分之13的税率怎么算如何算百分之13的税率
  • 直辖市税务局
  • 千兆交换机涨价
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设