#!coding=utf-8
import multiprocessing
def consumer(pipe):
output_p , input_p = pipe
input_p.close() #关闭管道的输入端
while True:
try:
item = output_p.recv()
except EOFError:
break
print item
print ("consumer done")
#生产项目并将其放到队列上
def producer(sequence, input_p):
for item in sequence:
input_p.send(item)
if __name__ == "__main__":
#创建管道
(output_p , input_p ) = multiprocessing.Pipe()
#启动使用者进程
cons_p = multiprocessing.Process(target=consumer, args=((output_p , input_p ),))
cons_p.start()
#关闭生产者中的输出管道
output_p.close()
#生产项目
sequence = [1,2,3,4]
producer(sequence, input_p)
#关闭输入管道,表示完成
input_p.close()
#等待使用者进行关闭
cons_p.join()
相关推荐
用python语言制作的管道小鸟游戏,可以通过键盘的空格键来控制小鸟的上下移动
python3.6版本进程之间通信,以上是python进程之间通信
一个Python模块,帮助你构建复杂管道的批处理作业。它处理依赖项决议,工作流管理、可视化等。它还附带了Hadoop支持内置的。
python管道 创建一个测试python管道
管道非侵入性的Python管道。 只有管道。 如果您想要更多的功能性工具,则应该寻找另一个库。 该代码存储库已移至 ,在此处进行积极维护,并有更多类似的工具。安装 pip install only-pipe或从github获取 pip ...
Phyloboost是一个python管道,它允许从序列的输入数据集中构造,增强和可视化基于相似度集群的树集。 终点是一个数据对象,可以探索或用来量化出现在用作输入的任何数据集中的系统发育信号。 尽管最初是作为一种...
扫描仪 用于识别基因组和元基因组中IS(插入序列)元素的python管道目录发行历史接触 概述ISEScan是用于识别基因组中IS(插入序列)元素的python管道。 它包括一个选项,用于报告完整的IS元素或完整和部分IS元素。 ...
hiv-variation:评估艾滋病毒变异性的Python管道和常用方法
mario:为您的shell提供强大的Python管道
骨管 带有多派遣的Python管道 可以与bones_data中的代数类型系统一起使用 fns可以为null,一元,二进制,rau和副词形式 包装和展开结构的实用程序
易语言DOS管道技术源码。@易语言入门教程。
本文实例讲述了Python实现处理管道的方法。分享给大家供大家参考。具体分析如下: Linux下的可以施展的最炫的魔法是什么?相信不同的人说法不同,但是如果没有管道,那么恐怕在绚丽魔法的都会失去魔力 这里就介绍...
管道模式的python实现,包括配置文件的解析,使用networkx进行processor的管理等
主要介绍了python中管道用法,实例分析了管道的创建、输入、输出及关闭等技巧,需要的朋友可以参考下
TPOT 一种使用遗传编程优化机器学习管道的Python自动机器学习工具
Python小鸟管道游戏(素材 + 代码)
# 执行外部shell命令, 输出结果输出管道 p = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) p.wait() # 从标准输出读出shell命令的输出结果 #rt = p.stdout.read()....
基于Python的含体积型缺陷管道剩余强度评价.pdf
本代码为python游戏小鸟管道,本人一枚学生党,希望大家多多支持谢谢。
python——管道小鸟(代码;素材)全齐了,下载就能用