偽代碼如下：

cons_p1 = multiprocessing.Process(target=consumer,args=((output_p,input_p),1))
cons_p1.start()
cons_p2 = multiprocessing.Process(target=consumer,args=((output_p,input_p),1))
cons_p2.start()

以上2個消費(fèi)者分別在兩個進(jìn)程中執(zhí)行，等待 數(shù)據(jù)：

while True:
    try:
        item = output_p.recv()     # 等待數(shù)據(jù)
    except EOFError:
        break
    print("%s消費(fèi)：%s" % (id,item)) 
    

生產(chǎn)者再主進(jìn)程 生產(chǎn)數(shù)據(jù)，并發(fā)送給管道：

input_p.send(item)

問題： 目前程序運(yùn)行結(jié)果，如果消費(fèi)的速度慢一些，兩個進(jìn)程可以正常從管道獲得數(shù)據(jù)。逐一消費(fèi)。
如果消費(fèi)速度快了。則某個進(jìn)程 會 EOFError 退出。

請問如何能在多進(jìn)程程序中，合理的共用管道？或者正確的姿勢是什么呢？