#!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")#生產(chǎn)項目并將其放到隊列上def producer(sequence, input_p):  for item in sequence:    input_p.send(item)if __name__ == "__main__":  #創(chuàng)建管道  (output_p , input_p ) = multiprocessing.Pipe()  #啟動使用者進程  cons_p = multiprocessing.Process(target=consumer, args=((output_p , input_p ),))  cons_p.start()  #關閉生產(chǎn)者中的輸出管道  output_p.close()  #生產(chǎn)項目  sequence = [1,2,3,4]  producer(sequence, input_p)  #關閉輸入管道，表示完成  input_p.close()  #等待使用者進行關閉  cons_p.join()