boost 条件变量

// boost 条件变量
// 做个简单的笔记

#include <boost/thread/mutex.hpp>
#include <boost/thread/condition.hpp>


boost::mutex m_mutex;
boost::condition_variable_any m_cond_var;


// 加锁
do
{
    boost::mutex::scoped_lock Lock(m_mutex);
    // other doing
}
while (false);
// 唤醒沉睡的线程
m_cond_var.notify_all();



// 进入条件变量沉睡，直到通知的到来。
// 调用wait 之前必须加锁成功
// 因为在wait() 中会首先释放锁。
// 同时，当wait() 函数返回后，该函数会将锁拿到，
// 所以wait()  函数返回后，是持有该锁的状态返回的。
m_mutex.lock();
m_cond_var.wait(m_mutex);
m_mutex.unlock();

// 定时休眠
{
    boost::mutex::scoped_lock lk(m_mutex);
    if (m_cond_var.timed_wait(
        lk, get_system_time() + posix_time::seconds(1)))
    {
        线程被 notify 唤醒
    }
    else
    {
        超时
    }
}

// 消费者线程使用条件变量
void Consumer()
{
    while (true)
    {
        {
            boost::mutex::scoped_lock lk(m_mutex);
            // 每次进入条件变量休眠之前都要判断是否满足条件进入条件变量。
            // 这一步很容易忘记
            while (满足进入条件变量的条件)
                m_cond_var.wait(lk);
            // 从集合中提取需要的数据
            // 块结束，lk 会自动释放锁
        }

        ...  // 处理从集合中得到的数据
    }
}