生產者消費者模型

def

consumer():
r = ''
while
true:
n = yield
r        
ifnot
n:            
return
print('
[consumer] consuming %s...
' %n)
r = '
200 ok
'def
produce(c):
c.send(none)
n =0
while n < 5:
n = n + 1
print('
[producer] producing %s...
' %n)
r =c.send(n)
print('
[producer] consumer return: %s
' %r)
c.close()
c =consumer()
produce(c)

# 執行結果為

[producer] producing 1...
[consumer] consuming 1...
[producer] consumer 
return: 200ok
[producer] producing 2...
[consumer] consuming 2...
[producer] consumer 
return: 200ok
[producer] producing 3...
[consumer] consuming 3...
[producer] consumer 
return: 200ok
[producer] producing 4...
[consumer] consuming 4...
[producer] consumer 
return: 200ok
[producer] producing 5...
[consumer] consuming 5...
[producer] consumer 
return: 200 ok

注意到consumer函式是乙個generator，把乙個consumer傳入produce後：

首先呼叫c.send(none)啟動生成器；

然後，一旦生產了東西，通過c.send(n)切換到consumer執行；

consumer通過yield拿到訊息，處理，又通過yield把結果傳回；

produce拿到consumer處理的結果，繼續生產下一條訊息；

produce決定不生產了，通過c.close()關閉consumer，整個過程結束。

整個流程無鎖，由乙個執行緒執行，produce和consumer協作完成任務，所以稱為「協程」，而非執行緒的搶占式多工。

生產者消費者模型

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

生產者消費者模型

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

生產者消費者模型

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