不要对多个用户使用管道。documentation显式地表示,当两个以上的进程读取或写入时,它将被损坏。你有;两个读者。在The two connection objects returned by Pipe() represent the two ends of the pipe. Each connection object has send() and recv() methods (among others). Note that data in a pipe may become corrupted if two processes (or threads) try to read from or write to the same end of the pipe at the same time. Of course there is no risk of corruption from processes using different ends of the pipe at the same time.

所以使用Queue,或者JoinableQueue。在from multiprocessing import Process, JoinableQueue

from Queue import Empty

import time

def consumer(que, pid):

while True:

try:

item = que.get(timeout=10)

print("%s consume:%s" % (pid, item))

que.task_done()

except Empty:

break

print('Consumer done')

def producer(sequence, que):

for item in sequence:

print('produce:', item)

que.put(item)

time.sleep(1)

if __name__ == '__main__':

que = JoinableQueue()

# create two consumer process

cons_p1 = Process(target=consumer, args=(que, 1))

cons_p1.start()

cons_p2 = Process(target=consumer, args=(que, 2))

cons_p2.start()

sequence = [i for i in range(10)]

producer(sequence, que)

que.join()

cons_p1.join()

cons_p2.join()

python管道怎么使用_如何在多个流程中正确使用管道(2)相关推荐

  1. python字符串单个替换_如何用变量替换列表中的单个字符串?

    我正在编写一个脚本,用python为程序maya创建一个命名约定. 我将使用它来命名脚本创建的所有对象.在 例如,以左膝关节为例.脚本会传递这样的信息 ("bind"," ...

  2. python json提取器_【编号0004】爬虫中常用到的数据提取手段

    使用爬虫抓取网上公开的网页数据时,经常需要使用各种技能去解析到手的响应. 本篇文章,重点介绍下,数据提取时,有哪些常见的方法 0. 背景交代 编程语言:Python 提取方式:Python库 1. X ...

  3. python 回归去掉共线性_一文讲解机器学习算法中的共线性问题

    多重共线性是使用线性回归算法时经常要面对的一个问题.在其他算法中,例如决策树和贝叶斯,前者的建模过程是逐步递进,每次拆分只有一个变量参与,这种建模机制含有抗多重共线性干扰的功能:后者干脆假定变量之间是 ...

  4. mac python安装太慢_【已解决】Mac中给pip3添加代理以提升下载python包的速度

    折腾: [未解决]Mac中Python 3.7安装TensorFlow 期间,用:pip3 install tensorflow 期间会去从下载python包 此处连接 files.pythonhos ...

  5. python docx 替换文字_查找并替换.docx文件中的文本 - Python

    我一直在寻找一种方法来查找和替换docx文件中的文本而运气不佳 . 我已经尝试过docx模块而无法使用它 . 最后,我使用zipfile模块计算了下面描述的方法,并替换了docx存档中的documen ...

  6. [转载] python实现语义分割_使用Keras实现深度学习中的一些语义分割模型

    参考链接: Keras中的深度学习-数据预处理 Keras-Sematic-Segmentation 使用Keras实现深度学习中的一些语义分割模型. 配置 tensorflow 1.13.1+ten ...

  7. python 绘图英文字体_如何在matplotlib和networkx中显示非英语字体?

    这是这个question的后续问题.因为它解决了一个更一般的问题,所以我把它作为一个新的问题.在 我有一个网络,其中节点的标签是波斯语(阿拉伯语字母表).当我试图使用networkx来显示我的网络时, ...

  8. python实现excel搜索_从几百个Excel中查找数据,用Python一分钟搞定

    今天给大家分享一个真实的办公自动化需求,日常办公肯定都会遇到的,大家一定要仔细阅读需求说明,在理解需求之后即可体会Python的强大! 一.需求说明 首先我们来看下今天的需求,有一份档案记录总表的Ex ...

  9. python读excel乱码_解决Python2.7读写文件中的中文乱码问题

    Python2.7对于中文编码的问题处理的并不好,这几天在爬数据的时候经常会遇到中文的编码问题.但是本人对编码原理不了解,也没时间深究其中的原理.在此仅从应用的角度做一下总结, 1.设置默认编码 在P ...

  10. python输出文本框_让tkinter在文本框中显示输出

    我试图创建一个小的GUI,当用户在文本框中输入一个数字时,它显示(作为标签)是否是素数.让tkinter在文本框中显示输出 我目前"工作"的代码(因为没有错误显示),但标签不会改变 ...

最新文章

  1. 【转】Node.js最新Web技术栈(2015年5月)
  2. python 处理xml pandas_Python数据处理分析,解决pandas中所有的Excel疑难杂症(上)
  3. jenkins api_接触Jenkins(Hudson)API,第2部分
  4. cad在线转低版本_为什么别人制图那么快?41个CAD实用技巧,3天轻松玩转CAD
  5. get mysql options_mysql命令的选项options
  6. Python下json中文乱码解决办法
  7. 史上最污技术解读,让你秒懂IT术语
  8. vue.js下载安装教程
  9. 手机QQ空间装逼代码收集
  10. 群晖7.0搭建discuz论坛
  11. 数论概论 第三章 勾股数组与单位圆
  12. 专业技术计算机应用能力考试ppt2007,全国专业技术人员计算机应用能力考试PPT题库.pdf...
  13. html不间断滚动图片,不间断循环滚动图片,jsp网页代码
  14. 大数据分析——暑期黑马《延禧攻略》到底有多火!
  15. 【电源设计】01电源参数及LDO
  16. Python:Turtle图形绘制
  17. android微信怎么建群,微信群空间是什么?如何创建微信群空间?
  18. TX2跑通yolov4
  19. Koa2框架的原理解析和实现
  20. 销售人员面试题之市场问题

热门文章

  1. 英特尔王庆连续四年担任OpenStack基金会个人独立董事
  2. 【MTSP】基于matlab遗传算法求解多旅行商问题【含Matlab源码 1339期】
  3. 【图像边缘检测】基于matlab GUI Sobel+Prewitt+Canny算子图像边缘检测(带面板)【含Matlab源码 1045期】
  4. python 抢红包 不越狱_这个Python脚本牛逼了,秒抢红包and无视撤回消息
  5. 男生学计算机怎么样,男生学计算机专业好不好?
  6. php 锁机制 stream,Php+redis+锁机制实现高并发秒杀抢购解决方案
  7. 最大连续子数组和 动态规划_53. 最大子序和(动态规划)
  8. java 映射servlet,java – 将映射或对象从jsp传递到servlet
  9. mysql sleep进程 java_请教java更新mysql,更新进程sleep
  10. java消息头_java中怎么进行头消息校验