python中管道用法入门实例

概述本文实例讲述了python中管道用法。分享给大家供大家参考。具体如下：#!coding=utf-8

本文实例讲述了python中管道用法。分享给大家供大家参考。具体如下：

#!Coding=utf-8import multiprocessingdef 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中管道用法入门实例全部内容，希望文章能够帮你解决python中管道用法入门实例所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。