首页 > 代码库 > Linux组件封装(二) 条件变量Condition的封装
Linux组件封装(二) 条件变量Condition的封装
声明代码如下:
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 : NonCopyable11 {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 }
Linux组件封装(二) 条件变量Condition的封装
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。