class BoundedBlockingQueue {
private:
int capacity;
list<int> bq;
condition_variable cv;
mutex mu;
public:
BoundedBlockingQueue(int capacity) {
this->capacity=capacity;
}
void enqueue(int element) {
unique_lock<mutex> lck(mu);
while(bq.size()==capacity) cv.wait(lck);
bq.push_front(element);
cv.notify_all(); // 通知 可读
}
int dequeue() {
unique_lock<mutex> lck(mu);
while(bq.size()==0) cv.wait(lck);
int ret=bq.back();
bq.pop_back();
lck.unlock();
if(bq.size()<capacity) cv.notify_all(); //通知可写
return ret;
}
int size() {
unique_lock<mutex> lck(mu);
int size=bq.size();
return size;
}
};
C++实现一个简单的阻塞队列
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- 一.解法 https://leetcode-cn.com/problems/implement-queue-usi...
