生產者消費者模型

生產者消費者模型就是通過乙個容器解決它們之間的強耦合問題，生產者與消費者之間依靠阻塞佇列進行通訊，生產者與消費者之間不直接通訊，這樣平衡了二者之間的處理能力，這裡使用了程序、執行緒以及生成器實現了生產者消費者模型。

使用程序的方式會耗費大量cpu的資源（包括程序的建立、切換、銷毀）；執行緒的方式相比程序來講切換會較少損耗cpu的資源；協程的方式理論上來講cpu的利用率達到100%，所以協程應該是較為理想的選擇。

from multiprocessing import

process
from multiprocessing import
queue
defproducer(q, name):
#生產者生產20個資料
for i in range(20):
q.put(str(i))
print("
%s生產第%s個
" %(name, i))
defconsumer(q, name):
while
true:
#從佇列中獲取資料
data =q.get()
ifdata:
print("
%s消費第%s個
" %(name, data))
else
:            
break
if__name__ == '
__main__':
q =queue()
#建立10個生產者
p_pro_list =
for i in range(10):
p_pro = process(target=producer, args=(q, "
生產者%s
" %i))
p_pro.start()
#等待所有的生產程序結束
for j in
p_pro_list:
j.join()
#然後再q中加入結束標示，用於消費者判斷佇列中是否還有資料,有多少個生產者加入多少個none
for k in
p_pro_list:
q.put(none)
#建立5個消費者
p_con_list =
for i in range(5):
p_con = process(target=consumer, args=(q, "
消費者%s
" %i))
p_con.start()
for j in
p_con_list:
j.join()

import

threading
from queue import
queue
defproducer(q, name):
for item in range(20):
q.put(item)
print("
%s-%s
" %(name, item))
defconsumer(q, name):
while
true:
item =q.get()
if item is
none:
break
print("
%s-%s
" %(name, item))
q.task_done()  
#任務完成後向佇列傳送乙個訊號通知一下
if__name__ == '
__main__':
q =queue()
#等待消費者消費q中的產品,與task_done搭配使用
q.join()
#生產者生產產品
t_pro = threading.thread(target=producer, args=(q, '
生產者生產'))
t_pro.start()
#消費者消費產品
t_con = threading.thread(target=consumer, args=(q, '
消費者消費'))
t_con.start()

協程的執行是由程式設計師控制而非作業系統，所以可以通過yield進行簡單的實現。

import

time
import
random
defconsumer():
while
true:
item = yield
print("
消費%s
" %item)
defproducer():
#第一次呼叫生成器時，使用next()語句或是send(none)，不能使用send傳送乙個非none的值，否則會出錯的。
c.send(none)  #
相當於c.next()啟用生成器
while
true:
time.sleep(1)
item = random.randint(1, 50)
print("
生產%s
" %item)
#進入生成器函式，此時將item賦值給yield並且傳回。相當於把item賦值給consumer中的item。
c.send(item)
if__name__ == '
__main__':
#消費者生成器
c =consumer()
producer()

生產者消費者模型

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

生產者消費者模型

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

生產者消費者模型

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