python中管道用法入门实例,python管道
python中管道用法入门实例,python管道
本文实例讲述了python中管道用法。分享给大家供大家参考。具体如下:
#!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基于multiprocessing的多进程创建方法,python多进程
- python抽象基类用法实例分析,python抽象实例分析
- python中__call__内置函数用法实例,python__call_
- Python获取系统默认字符编码的方法,python获取字符编码
- python协程用法实例分析,python协实例分析
- python中__slots__用法实例,python__slots_
- Python进程间通信用法实例,python进程用法实例
- python中引用与复制用法实例分析,python实例分析
- Python实现统计英文单词个数及字符串分割代码,
- Python中使用不同编码读写txt文件详解,
评论关闭