python中管道用法入门实例
2015-06-04 15:05
661 查看
#!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程序设计有所帮助。
您可能感兴趣的文章:
相关文章推荐
- Python动态类型的学习---引用的理解
- Python3写爬虫(四)多线程实现数据爬取
- 垃圾邮件过滤器 python简单实现
- 下载并遍历 names.txt 文件,输出长度最长的回文人名。
- install and upgrade scrapy
- Scrapy的架构介绍
- Centos6 编译安装Python
- 使用Python生成Excel格式的图片
- 让Python文件也可以当bat文件运行
- [Python]推算数独
- Python中zip()函数用法举例
- Python中map()函数浅析
- Python在CAM软件Genesis2000中的应用
- 使用Shiboken为C++和Qt库创建Python绑定
- FREEBASIC 编译可被python调用的dll函数示例
- Python 七步捉虫法
- Python实现的基于ADB的Android远程工具