Python之如何實現(xiàn)生產(chǎn)者消費者模型

小編給大家分享一下Python之如何實現(xiàn)生產(chǎn)者消費者模型，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

第一種使用queue隊列實現(xiàn)：

#生產(chǎn)者消費者模型 其實服務器集群就是這個模型
# 這里介紹的是非yield方法實現(xiàn)過程

import threading,time
import queue
q = queue.Queue(maxsize=10)

def Producer(anme):
 # for i in range(10):
 #  q.put('骨頭%s'%i)
 count = 1
 while True:
  q.put('骨頭%s'%count)
  print('生產(chǎn)了骨頭',count)
  count += 1
  time.sleep(1)

def Consumer(name):
 # while q.qsize() >0:
 while True:
  print('[%s] 取到[%s] 并且吃了它...'%(name,q.get()))
  time.sleep(1)

p = threading.Thread(target=Producer,args=('shenchanzhe',))
c = threading.Thread(target=Consumer,args=('xiaofeizhe01',))
c1 = threading.Thread(target=Consumer,args=('xiaofeizhe02',))

p.start()
c.start()
c1.start()

使用yield協(xié)程的方法來實現(xiàn)生產(chǎn)者和消費者：

#生產(chǎn)者和消費者，使用生成器的方式，就是一個簡單的并行，
import time
# 這是一個消費者 一直在等待完成吃包子的動作
def consumer(name):
 print('%s準備吃包子了！'%name) #打印出對應的消費者的名字
 while True: #執(zhí)行一個死循環(huán) 實際上就是需要調用時才會執(zhí)行，沒有調用就會停止在yield
  baozi = yield #在它就收到內容的時候后就把內容傳給baozi
  print('包子【%s】來了，被【%s】吃了'%(baozi,name))
def producer(name):
 c1 = consumer('A') #它只是把c1變成一個生成器
 c2 = consumer('B')
 c1.__next__() #第一個next只是會走到y(tǒng)ield然后停止
 c2.__next__()
 print('老子開始做包子了')
 for i in range(1,10):
  time.sleep(1)
  print('三秒做了兩個包子')
  c1.send(i) #這一步其實就是調用next方法的同時傳一個參數(shù)i給field接收，然后baozi=i
  c2.send(i+1)
  #其實這里是這樣的，在send的時候只是繼續(xù)執(zhí)行yield下面的語句，然后去去yield，再次停在這兒

# producer('aea')
c = consumer('aaa') #沒next一次就會將程序執(zhí)行一次
c.__next__()
c.__next__()
c.__next__()

以上是“Python之如何實現(xiàn)生產(chǎn)者消費者模型”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業(yè)資訊頻道！