消費者生產者模型

生產者生產的東西放到佇列裡，消費者消費掉東西。

import

time
import
random
from multiprocessing import
process,queue
defconsumer(q,name): # 消費者
while
true:
food =q.get()
if food is
none: # 如果消費完了，就會得到乙個none，然後結束
print('
%s獲取到了乙個空
'%name)
break
print('
%s消費了%s
' %(name,food))
time.sleep(random.randint(1,3))
defproducer(name,food,q): # 生產者
for i in range(4):
time.sleep(random.randint(1,3))
f = '
%s生產了%s%s
'%(name,food,i)
print
(f) q.put(f)
if__name__ == '
__main__':
q = queue(20)
p1 = process(target=producer,args=('
小明','包子'
,q))
p2 = process(target=producer, args=('
小紅','大餅'
, q))
c1 = process(target=consumer, args=(q,'小狗'
)) c2 = process(target=consumer, args=(q,'小豬'
)) p1.start()
p2.start()
c1.start()
c2.start()
p1.join() # 感知子程序生產完了
p2.join() # 感知子程序生產完了
q.put(none) # 就放入乙個none
q.put(none) # 就放入乙個none

生產者消費者模型

1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...

生產者消費者模型

生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...

生產者消費者模型

當佇列滿時，生產者需要等待佇列有空間才能繼續往裡面放入商品，而在等待的期間內，生產者必須釋放對臨界資源 即佇列 的占用權。因為生產者如果不釋放對臨界資源的占用權，那麼消費者就無法消費佇列中的商品，就不會讓佇列有空間，那麼生產者就會一直無限等待下去。因此，一般情況下，當佇列滿時，會讓生產者交出對臨界資...