import time,random
# 匯入multiprocessing模組下的queue類
from multiprocessing import process,queue
defproducer
(name,food,q)
:for i in
range(3
):res=
'%s%s'
%(food,i)
time.sleep(random.randint(1,
3))#模擬生產資料的時間
q.put(res)
# 加入佇列
print
('廚師[%s]生產了<%s>'
%(name,res)
)def
consumer
(name,q)
:while
true
: res=q.get(
)# 從佇列取出
if res is
none
:break
time.sleep(random.randint(1,
3))#模擬處理資料的時間
print
('吃貨[%s]吃了<%s>'
%(name,res)
)if __name__ ==
'__main__'
: q=queue(
)# 生產者們
p1=process(target=producer,args=
('小egon'
,'蛋糕'
,q))
p2=process(target=producer,args=
('中egon'
,'烤串'
,q))
p3=process(target=producer,args=
('老egon'
,'羊湯'
,q))
# 消費者們
c1=process(target=consumer,args=
('小虎'
,q))
c2=process(target=consumer,args=
('老虎'
,q))
p1.start(
) p2.start(
) p3.start(
) c1.start(
) c2.start(
) p1.join(
)# 確保p1,p2,p3已經生產完畢
p2.join(
) p3.join(
) q.put(
none
)# 讓兩消費者接受,作為佇列已空的標識
q.put(
none
)print
('主'
)'''
缺點:手動新增佇列已空的標識,你需要清楚消費者個數,麻煩.
有需求就有滿足,joinablequeue可以解決這個問題
'''
import time,random
# 匯入joinablequeue類
from multiprocessing import process,joinablequeue
# 生產者
defproducer
(name,food,q)
:for i in
range(3
):res =
'%s%s'
%(food,i)
time.sleep(random.randint(1,
3))#模擬生產資料的時間
q.put(res)
print
('廚師[%s]生產了<%s>'
%(name,res)
)# 消費者
defconsumer
(name,q)
:while
true
: res = q.get(
)if res is
none
:break
time.sleep(random.randint(1,
3))#模擬生產資料的時間
print
('吃貨[%s]吃了<%s>'
%(name,res)
)# 消費者沒取走乙個就給q.join傳送乙個資訊,記錄已取走數量
q.task_done(
)if __name__ ==
'__main__'
: q = joinablequeue(
)# 生產者
p1 = process(target=producer,args=
("小egon"
,"蛋糕"
,q))
p2 = process(target=producer,args=
("中egon"
,"臭豆腐"
,q))
p3 = process(target=producer,args=
("老egon"
,"撒尿牛丸"
,q))
# 消費者
c1 = process(target=consumer,args=
("小虎"
,q))
c2 = process(target=consumer,args=
("老虎"
,q))
# 守護程序主程序結束 子程序也結束
c1.daemon=
true
c2.daemon=
true
p1.start(
) p2.start(
) p3.start(
) c1.start(
) c2.start(
) p1.join(
) p2.join(
) p3.join(
) q.join(
)#主程序等q內的資料被取乾淨了
print
('主'
)
生產者消費者模型
1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...
生產者消費者模型
生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...
生產者消費者模型
當佇列滿時，生產者需要等待佇列有空間才能繼續往裡面放入商品，而在等待的期間內，生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權，那麼消費者就無法消費佇列中的商品，就不會讓佇列有空間，那麼生產者就會一直無限等待下去。因此，一般情況下，當佇列滿時，會讓生產者交出對臨界資...