生產者消費者模型二(單 多模型)

2021-08-15 00:06:56 字數 2217 閱讀 2279



生產者——消費者問題(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 ...