非同步之生產者消費者模型 同步緩衝區的實現

2021-06-19 03:05:50 字數 910 閱讀 7915

適用於多個生產線程和多個消費執行緒之間的協作,生產者將資訊放入同步緩衝區,消費者從該緩衝區中讀取進行操作,可以指定特殊的「產品」來指示工作執行緒退出。

#ifndef __producer_consumer_hpp_

#define __producer_consumer_hpp_

#include class noncopyable

~noncopyable(){}

private:

noncopyable(const noncopyable&);

const noncopyable& operator=(const noncopyable&);

};templateclass syncbuffer

: public noncopyable

~syncbuffer()

void push_front(const syncdata& data)

void push_back(const syncdata& data)

void pop_front(syncdata& data)

void pop_back(syncdata& data)

private:

void get_cs_for_add(bool isget = true)else

}void get_cs_for_remove(bool isget = true)else

}std::dequebuffer_;

long max_size_;

handle empty_slot_event_;

handle full_slot_event_;

critical_section cs_;

};#endif // __producer_consumer_hpp_

生產者消費者模型

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

生產者消費者模型

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

生產者消費者模型

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