#!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)項(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ì)有所幫助。

您可能感興趣的文章:

相關(guān)文章

視覺(jué)直觀感受若干常用排序算法
這篇文章主要利用視覺(jué)直觀的幾種若干常用排序算法，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2017-04-04
Pytest框架之fixture詳解（一）
本文詳細(xì)講解了Pytest框架之fixture，文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
2022-06-06
python函數(shù)默認(rèn)參數(shù)使用避坑指南
這篇文章主要為大家介紹了python函數(shù)默認(rèn)參數(shù)使用的踩雷避坑詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2022-07-07
Pycharm編輯器功能之代碼折疊效果的實(shí)現(xiàn)代碼
這篇文章主要介紹了Pycharm編輯器功能之代碼折疊效果的實(shí)現(xiàn)代碼,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
2020-10-10
這篇文章主要介紹了Python多個(gè)裝飾器的調(diào)用順序?qū)嵗馕?文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-05-05