// 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()))

     {

         线程被 notify 唤醒

     }

     else

     {

         超时

     }

 }

 // 消费者线程使用条件变量

 void Consumer()

 {

     while (true)

     {

         {

             boost::mutex::scoped_lock lk(m_mutex);

             // 每次进入条件变量休眠之前都要判断是否满足条件进入条件变量。

             // 这一步很容易忘记

             while (满足进入条件变量的条件)

                 m_cond_var.wait(lk);

             // 从集合中提取需要的数据

             // 块结束，lk 会自动释放锁

         }

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

     }

 }