标签：des style blog color io 使用 strong 数据 sp
声明代码如下:
1 #ifndef CONDITION_H 2 #define CONDITION_H 3 4 #include <pthread.h> 5 #include "noncopyable.h" 6 7 class MutexLock; 8 9 10 class Condition : NonCopyable 11 { 12 public: 13 Condition(MutexLock &mutex); 14 ~Condition(); 15 16 void wait(); 17 void notify(); 18 void notifyAll(); 19 private: 20 pthread_cond_t _cond; 21 MutexLock &_mutex; 22 }; 23 24 #endif
需要注意:
1.wait必须在加锁条件下调用
2.notify一次唤醒一个线程，通常用来通知资源可用
3.notifyAll一次通知多个线程，通常用来通知状态的变化。滥用broadcast会导致"惊群"问题。
使用wait必须采用while判断，原因在于:
1.如果采用if，最多判断一次
2.线程A等待数据，阻塞在full上，那么当另一个线程放入产品时，通知A去拿数据，此时另一个线程B抢到锁，直接进入临界区，取走资源。A重新抢到锁，（因为采用的是if，所以不会判断第二次）进去临界区时，已经没有资源。
3.防止broadcast的干扰，如果获得一个资源，使用broadcast会唤醒所有等待的线程，那么多个线程被唤醒，但最终只有一个能拿到资源，这就是所谓的“惊群效应”。
cpp代码实现如下：
1 #include "Condition.h" 2 #include "MutexLock.h" 3 #include <assert.h> 4 5 Condition::Condition(MutexLock &mutex) 6 :_mutex(mutex) 7 { 8 TINY_CHECK(!pthread_cond_init(&_cond, NULL)); 9 } 10 11 Condition::~Condition() 12 { 13 TINY_CHECK(!pthread_cond_destroy(&_cond)); 14 } 15 16 void Condition::wait() 17 { 18 assert(_mutex.isLocked()); 19 TINY_CHECK(!pthread_cond_wait(&_cond, _mutex.getMutexPtr())); 20 } 21 22 void Condition::notify() 23 { 24 TINY_CHECK(!pthread_cond_signal(&_cond)); 25 } 26 27 void Condition::notifyAll() 28 { 29 TINY_CHECK(!pthread_cond_broadcast(&_cond)); 30 }
标签：des style blog color io 使用 strong 数据 sp
原文地址：http://www.cnblogs.com/gjn135120/p/4008570.html
