#!coding=utf-8
import multiprocessing
def 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)項目并將其放到隊列上
def producer(sequence, input_p):
  for item in sequence:
    input_p.send(item)
if __name__ == "__main__":
  #創(chuàng)建管道
  (output_p , input_p ) = multiprocessing.Pipe()
  #啟動使用者進(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)項目
  sequence = [1,2,3,4]
  producer(sequence, input_p)
  #關(guān)閉輸入管道，表示完成
  input_p.close()
  #等待使用者進(jìn)行關(guān)閉
  cons_p.join()