生產者消費者模型

生產者消費者問題（英語：producer-consumer problem），也稱有限緩衝問題（英語：bounded-buffer problem），是乙個多程序同步問題的經典案例。該問題描述了共享固定大小緩衝區的兩個程序——即所謂的「生產者」和「消費者」——在實際執行時會發生的問題。生產者的主要作用是生成一定量的資料放到緩衝區中，然後重複此過程。與此同時，消費者也在緩衝區消耗這些資料。該問題的關鍵就是要保證生產者不會在緩衝區滿時加入資料，消費者也不會在緩衝區中空時消耗資料。

要解決該問題，就必須讓生產者在緩衝區滿時休眠（要麼乾脆就放棄資料），等到下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒，開始往緩衝區新增資料。同樣，也可以讓消費者在緩衝區空時進入休眠，等到生產者往緩衝區新增資料之後，再喚醒消費者。

在多執行緒程式中可能存在資源競爭問題。一般是通過訊號量和互斥鎖來保證執行緒安全。

執行緒安全的生產者和消費者模式。

具體過程簡單的說來就是：當緩衝區空時消費者阻塞，生產者忙；當緩衝區滿時，生產者阻塞，消費者忙。

#include 
#include 
#include 
#include 
#include 
#include 
#include 
using namespace std;
template
class block_buffer);
_content.push_back(item)
;		_con_var.notify_all();
cout<<
"push item into buffer "
<< item<
}	t dequeue())
;		t item = _content.front();
_content.pop_front();
_con_var.notify_all();
cout<<
"delete item from buffer "
<
return item;}}
;template
class producer
void produce()}
int produce_function()}
;template
class consumer
void consume()}
void consume_function(int &item)};
int main(
)

執行結果。

push item into buffer 18467 delete item from buffer 18467 push item into buffer 26500 delete item from buffer 26500 push item into buffer 15724 push item into buffer 29358 delete item from buffer 15724 push item into buffer 24464 delete item from buffer 29358 push item into buffer 28145 delete item from buffer 24464

生產者消費者模型

生產者消費者模型

生產者消費者模型

生產者消費者模型

相關推薦