位置: 编程技术 - 正文

简单谈谈python中的Queue与多进程(简述python语言)

编辑:rootadmin

推荐整理分享简单谈谈python中的Queue与多进程(简述python语言),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python简要介绍,谈下python的gil,python简要介绍,简述python语言,python简要介绍,简述python语言,谈下python的gil,简述python语言,内容如对您有帮助,希望把文章链接给更多的朋友!

最近接触一个项目,要在多个虚拟机中运行任务,参考别人之前项目的代码,采用了多进程来处理,于是上网查了查python中的多进程

一、先说说Queue(队列对象)

Queue是python中的标准库,可以直接import 引用,之前学习的时候有听过著名的“先吃先拉”与“后吃先吐”,其实就是这里说的队列,队列的构造的时候可以定义它的容量,别吃撑了,吃多了,就会报错,构造的时候不写或者写个小于1的数则表示无限多

import Queue

q = Queue.Queue()

向队列中放值(put)

q.put(‘yang')

q.put(4)

q.put([‘yan','xing'])

在队列中取值get()

默认的队列是先进先出的

>>> q.get()‘yang'>>> q.get()4>>> q.get()[‘yan', ‘xing']

当一个队列为空的时候如果再用get取则会堵塞,所以取队列的时候一般是用到

get_nowait()方法,这种方法在向一个空队列取值的时候会抛一个Empty异常

所以更常用的方法是先判断一个队列是否为空,如果不为空则取值

队列中常用的方法

Queue.qsize() 返回队列的大小Queue.empty() 如果队列为空,返回True,反之FalseQueue.full() 如果队列满了,返回True,反之FalseQueue.get([block[, timeout]]) 获取队列,timeout等待时间Queue.get_nowait() 相当Queue.get(False)非阻塞 Queue.put(item) 写入队列,timeout等待时间Queue.put_nowait(item) 相当Queue.put(item, False)

二、multiprocessing中使用子进程概念

from multiprocessing import Process

可以通过Process来构造一个子进程

p = Process(target=fun,args=(args))

简单谈谈python中的Queue与多进程(简述python语言)

再通过p.start()来启动子进程

再通过p.join()方法来使得子进程运行结束后再执行父进程

三、在multiprocessing中使用pool

如果需要多个子进程时可以考虑使用进程池(pool)来管理

from multiprocessing import Pool

pool创建子进程的方法与Process不同,是通过

p.apply_async(func,args=(args))实现,一个池子里能同时运行的任务是取决你电脑的cpu数量,如我的电脑现在是有4个cpu,那会子进程task0,task1,task2,task3可以同时启动,task4则在之前的一个某个进程结束后才开始

上面的程序运行后的结果其实是按照上图中1,2,3分开进行的,先打印1,3秒后打印2,再3秒后打印3

代码中的p.close()是关掉进程池子,是不再向里面添加进程了,对Pool对象调用join()方法会等待所有子进程执行完毕,调用join()之前必须先调用close(),调用close()之后就不能继续添加新的Process了。

当时也可以是实例pool的时候给它定义一个进程的多少

如果上面的代码中p=Pool(5)那么所有的子进程就可以同时进行

三、多个子进程间的通信

多个子进程间的通信就要采用第一步中说到的Queue,比如有以下的需求,一个子进程向队列中写数据,另外一个进程从队列中取数据,

四、关于上面代码的几个有趣的问题

如果main函数写成上面的样本,本来我想要的是将会得到一个队列,将其作为参数传入进程池子里的每个子进程,但是却得到

RuntimeError: Queue objects should only be shared between processes through inheritance

的错误,查了下,大意是队列对象不能在父进程与子进程间通信,这个如果想要使用进程池中使用队列则要使用multiprocess的Manager类

这样这个队列对象就可以在父进程与子进程间通信,不用池则不需要Manager,以后再扩展multiprocess中的Manager类吧

关于锁的应用,在不同程序间如果有同时对同一个队列操作的时候,为了避免错误,可以在某个函数操作队列的时候给它加把锁,这样在同一个时间内则只能有一个子进程对队列进行操作,锁也要在manager对象中的锁

Python设计模式之抽象工厂模式 python面向对象编程入门,我们需要不断学习进步"""抽象工厂模式的实现"""importrandomclassPetShop:"""宠物商店"""def__init__(self,animal_factory=None):"""宠物工厂是我

Python爬取京东的商品分类与链接 前言本文主要的知识点是使用Python的BeautifulSoup进行多层的遍历。如图所示。只是一个简单的哈,不是爬取里面的隐藏的东西。示例代码frombs4importBeautiful

python实现实时监控文件的方法 在业务稳定性要求比较高的情况下,运维为能及时发现问题,有时需要对应用程序的日志进行实时分析,当符合某个条件时就立刻报警,而不是被动等

标签: 简述python语言

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

上一篇:利用Python自动监控网站并发送邮件告警的方法(python自动化监控)

下一篇:Python设计模式之抽象工厂模式(python 设计)

  • 员工离职再入职个税人员信息该如何录入?
  • 普票税率错了要收回作废吗
  • 增值税申报表第25行怎么填
  • 借方是收入还是支出 正负号
  • 建筑工程怎么确定施工工程进度
  • 计提坏账准备怎么理解
  • 定额发票上可以盖章吗
  • 应交税费消费税分录
  • 职工宿舍楼日常管理制度
  • 政府补贴项目申报流程
  • 商业地产会计核算流程
  • 公司筹建期间发生的费用没有发票
  • 什么时候需要计算环境熵变
  • 一般纳税人两费减免会计分录
  • 劳务服务公司业务范围
  • 没有成立工会的企业要交工会筹备金吗
  • 应付账款对账的流程和技巧
  • 公司购买商业保险如何入账
  • 三证合一后未办理税务登记
  • 认证费用计入什么账户
  • 子公司能转让吗
  • 安全生产费怎么算
  • 一般纳税人汇算清缴操作流程
  • WIN10专业版永久激活
  • Windows自带的截图
  • 进口关税和增值税
  • 库乐队是苹果自带的嘛
  • 企业自行搬迁需要交税吗
  • 高速公路电子发票抵扣进项税
  • PHP:parse_ini_string()的用法_Filesystem函数
  • 使用Zttp简化Guzzle 调用
  • 通行费发票认证怎么操作
  • 长期负债和应付账款
  • ip命令查看ip地址
  • 分公司在外地,企业怎么交税
  • 土地增值税采用
  • 企业财政拨款所得免税吗
  • js reverse
  • 计划资产产生的股利
  • php安装不了
  • MySQL默认字符集修改
  • 债权人债务重组损益计入什么科目
  • 员工工资扣工作服押金怎么做账呢
  • 咨询服务业主营业务成本
  • 增值税月末结转处理
  • 预缴增值税怎么计提
  • 递延所得税资产和负债账务处理
  • 权益法下股权投资转让
  • 工地零电零水布置图
  • 不动产租赁按简易计税吗
  • 结转未交增值税为什么是零
  • 机票改签手续费能报销吗
  • 存贷款利率计算公式
  • 契税发票错了能作废吗
  • 新公司期初余额怎么算
  • 信息技术服务费可以全额抵扣吗
  • 增资协议书范本合同
  • 小规模纳税人手工帐怎么做
  • 冲暂估成本能冲部分暂估吗
  • ubuntu16.04.1下 mysql安装和卸载图文教程
  • winxp系统安装教程
  • ubuntu怎么禁用nouveau
  • freebsd安装mysql
  • WINDOWS系统中删除放入回收站的文件占用什么空间
  • 新买的苹果电脑没有电
  • Linux网络编程实时传输视频
  • win7或win8、win8.1系统下安装ubuntu实现双系统图文教程
  • xshell使用ssh命令远程连接linux
  • win8系统如何
  • win8无法安装inter显卡驱动
  • unity3d游戏引擎支持几种平台发布?
  • 显示解析包时出错是怎么回事
  • js获取浏览器的cookie
  • 税务非正常户解除申请怎么写
  • 个人出租商铺个人所得税计算
  • 税款所属期起怎么填写
  • 政府补贴 收入
  • 郑州地铁客服热线电话
  • 宁德市蕉城区地图全图最新
  • 宁波市国家税务局网上办税服务厅
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

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

    友情链接: 武汉网站建设