生產者——消費者問題（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)
(ir->item_buffer)[ir->write_position] = item; // 寫入產品.
(ir->write_position)++; // 寫入位置後移.
std::cout << "producer thread: " << std::this_thread::get_id() << "is producing the:" << item << "^th item..." << std::endl;
(gitemrepository.item_counter)++;
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() // 生產者任務}}
//多個消費者會對緩衝區進行讀寫，所以需要特殊處理
void consumertask() // 消費者任務
}void inititemrepository(itemrepository *ir)
int main()
生產消費模型 多生產者vs多消費者
使用場景 遊戲中多個玩家生產任務，伺服器多執行緒處理任務,netty工作執行緒收到客戶端傳來資料，生成任務後，加入到任務佇列中 public abstract class basetask 任務管理器 public class mutitaskmanager private final static...
生產者消費者模型
1.生產者消費者問題 producer consumer 有限緩衝，多執行緒同步。生產者執行緒和消費者執行緒共享固定大小緩衝區。2.關鍵是保證生產者不會再緩衝區滿時加入資料，消費者不會在緩衝區空時消耗資料。3.解決辦法 讓生產者在緩衝區滿時休眠，等下次消費者消耗緩衝區中的資料的時候，生產者才能被喚醒...
生產者消費者模型
生產者與消費者 3,2,1 三種關係 生產者與消費者 互斥，同步 消費者與消費者 互斥 生產者與生產者 互斥 條件變數 int pthread cond destroy pthread cond t cond int pthread cond init pthread cond t restrict...