本文實(shí)例講述了python中管道用法。分享給大家供大家參考。具體如下：

#!coding=utf-8import multiprocessingdef consumer(pipe):  output_p , input_p = pipe  input_p.close() #關(guān)閉管道的輸入端  while True:    try:      item = output_p.recv()    except EOFError:      break    print item  print ("consumer done")#生產(chǎn)項(xiàng)目并將其放到隊(duì)列上def producer(sequence, input_p):  for item in sequence:    input_p.send(item)if __name__ == "__main__":  #創(chuàng)建管道  (output_p , input_p ) = multiprocessing.Pipe()  #啟動(dòng)使用者進(jìn)程  cons_p = multiprocessing.Process(target=consumer, args=((output_p , input_p ),))  cons_p.start()  #關(guān)閉生產(chǎn)者中的輸出管道  output_p.close()  #生產(chǎn)項(xiàng)目  sequence = [1,2,3,4]  producer(sequence, input_p)  #關(guān)閉輸入管道，表示完成  input_p.close()  #等待使用者進(jìn)行關(guān)閉  cons_p.join()

希望本文所述對(duì)大家的Python程序設(shè)計(jì)有所幫助。