python學習 40 生產者和消費者模型

import

time
def buy(name):                      #
消費者print('
%s上街去買蛋
' %name)
while
true:
eggs=yield
print('
%s買了%s
' %(name,eggs))
def product_eggs():              #
生產者    a =buy('小明'
)    a.
__next__
()    
for i  in range(1,11):
time.sleep(1)
a.send(
'%s個雞蛋
' %i)
product_eggs()

執行結果：

小明上街去買蛋

小明買了1個雞蛋
小明買了2個雞蛋
小明買了3個雞蛋
小明買了4個雞蛋
小明買了5個雞蛋
小明買了6個雞蛋
小明買了7個雞蛋
小明買了8個雞蛋
小明買了9個雞蛋
小明買了10個雞蛋
process finished with exit code 0

5 12 生產者和消費者

一 生產者和消費者之間的關係 1 生產者將生產出來的資訊不斷存入乙個區域內，消費者將資訊從該區域內不斷讀取出來 生產者錄入資訊 消費者讀取資訊 例 電影票 public class movie public void setname string name public string getinfo...

python3 生產者消費者

code from queue import queue from threading import thread 用來表示終止的特殊物件 sentinel object a thread that produces data def producer out q for i in range 10...

kafka學習筆記（二） 生產者介紹

生產者傳送訊息的過程 分割槽原則 資料可靠性保證 acsk 0 producer不等待broker的ack，這樣可以提供最低的延遲，broker一接收到還沒有寫入到磁碟就返回ack，當broker出現故障的時候可能會丟失資料 1 producer等待broker返回ack，partition的lea...