muduo之BlockingQueue

BlockingQueue是muduo是无界队列，利用队列(deque)实现，向队列中加入和取出元素用互斥量和条件变量结合的方式来操作，就是一个线程同步的问题。

BlockingQueue.h

// Use of this source code is governed by a BSD-style license
// that can be found in the License file.
//
// Author: Shuo Chen (chenshuo at chenshuo dot com)#ifndef MUDUO_BASE_BLOCKINGQUEUE_H
#define MUDUO_BASE_BLOCKINGQUEUE_H#include "muduo/base/Condition.h"
#include "muduo/base/Mutex.h"#include <deque>
#include <assert.h>namespace muduo
{
//互斥锁配合条件变量是为了防止线程不停的主动获得锁、检查条件、释放锁、再获得锁、再检查、再释放，一直到满足运行的条件的时候才行
template<typename T>
class BlockingQueue : noncopyable  //无界阻塞队列
{public:BlockingQueue(): mutex_(),notEmpty_(mutex_),   //条件变量queue_(){}void put(const T& x){MutexLockGuard lock(mutex_);queue_.push_back(x);notEmpty_.notify(); // wait morphing saves us// http://www.domaigne.com/blog/computing/condvars-signal-with-mutex-locked-or-not/}void put(T&& x){MutexLockGuard lock(mutex_);queue_.push_back(std::move(x));notEmpty_.notify();//向所有线程提示条件已发生}T take(){MutexLockGuard lock(mutex_);// always use a while-loop, due to spurious wakeupwhile (queue_.empty()){notEmpty_.wait();  //等待条件发生}assert(!queue_.empty());T front(std::move(queue_.front()));//掏空queue_.front()，queue_.front()就变为空了queue_.pop_front();return std::move(front);}size_t size() const{MutexLockGuard lock(mutex_);return queue_.size();}private:mutable MutexLock mutex_;Condition         notEmpty_ GUARDED_BY(mutex_);std::deque<T>     queue_ GUARDED_BY(mutex_);
};}  // namespace muduo#endif  // MUDUO_BASE_BLOCKINGQUEUE_H

muduo之BlockingQueue相关推荐

15muduo_base库源码分析（六）
1.BoundedBlockingQueue<T>(有界缓冲区) BoundedBlockingQueue.h // Use of this source code is governed ...
双缓冲异步日志（Async Logging）
文章目录一.日志系统简介二.功能需求三.性能需求四.高效的异步日志 1.异步日志的概念 2.双缓冲异步日志解析 3.AsyncLogging源码 4.代码运行图示五.双缓冲异步日志的相关问题 ...
muduo BlockingQueue详解
1. 简介利用条件变量和std::deque实现阻塞队列 2. 类与接口插入数据,有2个版本 void put(const T& x) 非常量可以初始化一个底层const,反过来却不行可 ...
muduo之ThreadPool
muduo中的线程池. ThreadPool.h // Use of this source code is governed by a BSD-style license // that can b ...
muduo学习笔记 - 第2章线程同步精要
第2章线程同步精要 2.1 互斥器 (mutex) 互斥器保护了临界区,任何时刻最多只能有一个线程在mutex划出的临界区内活动推荐使用原则: 用RAII手法封装mutex的创建.销毁.加锁.解锁 ...
muduo网络库源码阅读Step by Step
Posted on: Nov 26 2015 Categories: muduo C++ Tags: muduo 一般写服务端程序都需要有一个称手的网络库来帮我们处理琐碎的网络通信细节,比如连接的建立 ...
Java并发编程之——BlockingQueue（队列）
一.什么是BlockingQueue BlockingQueue即阻塞队列,从阻塞这个词可以看出,在某些情况下对阻塞队列的访问可能会造成阻塞.被阻塞的情况主要有如下两种: 1. 当队列满了的时候进行入 ...
Java中Queue和BlockingQueue的区别
1.BlockingQueue:支持两个附加操作的 Queue,这两个操作是:检索元素时等待队列变为非空,以及存储元素时等待空间变得可用. 2.BlockingQueue 不接受 null 元素. 3 ...
muduo 与 boost asio 吞吐量对比
muduo (http://code.google.com/p/muduo) 是一个基于 Reactor 模式的 C++ 网络库,我在编写它的时候并没有以高并发高吞吐为主要目标,但出乎我的意料,pin ...

muduo之BlockingQueue

muduo之BlockingQueue相关推荐

最新文章

热门文章