python中管道用法入门实例
本文实例讲述了python中管道用法。分享给大家供大家参考。具体如下：
#!coding=utf-8
importmultiprocessing
defconsumer(pipe):
output_p,input_p=pipe
input_p.close()#关闭管道的输入端
whileTrue:
try:
item=output_p.recv()
exceptEOFError:
break
printitem
print("consumerdone")
#生产项目并将其放到队列上
defproducer(sequence,input_p):
foriteminsequence:
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程序设计有所帮助。
热门推荐
10 八一幼儿祝福语大全简短
11 公司乔迁食堂祝福语简短
12 婚礼结束聚餐祝福语简短
13 儿媳买车妈妈祝福语简短
14 毕业送礼老师祝福语简短
15 同事辞职正常祝福语简短
16 恭贺新婚文案祝福语简短
17 金店立秋祝福语简短英文
18 婆婆高寿祝福语大全简短