生產者——消費者問題（producer-consumer），又名：有界緩衝區（bounded-buffer）問題
單生產者——多消費者
設計要點：
當緩衝區滿已滿，而此時生產者還想向緩衝區中放入乙個新的資料項時。則讓生產者睡眠，待消費者從緩衝區中取出乙個或多個資料項時再喚醒生產者。
同樣的，當緩衝區滿已空，而此時消費者還想從緩衝區中取出乙個新的資料項時。則讓消費者睡眠，待生產者向緩衝區中放入乙個或多個資料項時再喚醒消費者。
同時，多個消費者，則需要多新增乙個條件變數，用來保證多個消費者之間對訊息佇列的互斥訪問。
**實現如下：（ide : vs2017）
#include"stdafx.h"
#include
#include
#include //sleep()函式需要包含的標頭檔案
#include
#include
#include
#include
using namespace std;
static const int kitemrepositorysize = 10; // item buffer size.
static const int kitemstoproduce = 100; // how many items we plan to produce.
class itemrepository
gitemrepository; // 產品庫全域性變數, 生產者和消費者操作該變數.
//生產者函式不需要特殊處理
void produceitem(itemrepository *ir, int item)
std::cout << "producer is producting the " << item << "^th item..." << std::endl;
(ir->item_buffer)[ir->write_position] = item; // 寫入產品.
(ir->write_position)++; // 寫入位置後移.
if (ir->write_position == kitemrepositorysize) // 寫入位置若是在佇列最後則重新設定為初始位置.
ir->write_position = 0;
(ir->repo_not_empty).notify_all(); // 通知消費者產品庫不為空.
lock.unlock(); // 解鎖.
}int consumeitem(itemrepository *ir)
/*std::cout << "consumer is consuming the " << ir->read_position << "^th item" << std::endl;*/
data = (ir->item_buffer)[ir->read_position]; // 讀取某一產品
(ir->read_position)++; // 讀取位置後移
std::cout << "consumer thread " << std::this_thread::get_id()
<< " is consuming the " << data << "^th item" << std::endl;
if (ir->read_position >= kitemrepositorysize) // 讀取位置若移到最後，則重新置位.
ir->read_position = 0;
(ir->repo_not_full).notify_all(); // 通知生產者產品庫不為滿.
lock.unlock(); // 解鎖.
return data; // 返回產品.
}void producertask() // 生產者任務
std::cout << "producer thread " << std::this_thread::get_id()
<< " is exiting..." << std::endl;
}//多個消費者會對緩衝區進行讀寫，所以需要特殊處理
void consumertask() // 消費者任務
else ready_to_exit = true;
lock.unlock();
if (ready_to_exit == true) break;}}
void inititemrepository(itemrepository *ir)
int main()
單生產者 多消費者模型
問題出處 生產者消費者問題 有乙個生產者在生產產品，這些產品將提供給若干個消費者去消費，為了使生產者和消費者能併發執行，在兩者之間設定乙個有多個緩衝區的緩衝池，生產者將它生產的產品放入乙個緩衝區中，消費者可以從緩衝區中取走產品進行消費，所有生產者和消費者都是非同步方式執行的，但它們必須保持同步，即不...
生產消費模型 多生產者vs多消費者
使用場景 遊戲中多個玩家生產任務，伺服器多執行緒處理任務,netty工作執行緒收到客戶端傳來資料，生成任務後，加入到任務佇列中 public abstract class basetask 任務管理器 public class mutitaskmanager private final static...
生產者消費者問題之多生產者 單消費者模型
與單生產者和單消費者模型不同的是，多生產者 單消費者模型中可以允許多個生產者同時向產品庫中放入產品。所以除了保護產品庫在多個讀寫執行緒下互斥之外，還需要維護生產者放入產品的計數器，如下 include include include include include static const int ...