本文實例講述了python中管道用法。分享給大家供大家參考。具體如下：
?
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 #!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程序設計有所幫助。
