Linux组件封装之二：Condition

本博文讨论Linux中的条件变量Condition的封装；

条件变量Condition 主要描述的是 线程间 的同步，即协作关系。

Linux中的条件变量通常涉及以下几个函数：

int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr);
int pthread_cond_signal(pthread_cond_t *cond);
int pthread_cond_broadcast(pthread_cond_t *cond);
int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);
int pthread_cond_destroy(pthread_cond_t *cond);

一、条件变量类（Condition）：

 1 #ifndef CONDITION_H_
 2 #define CONDITION_H_
 3
 4 #include "NonCopyable.h"
 5 #include "MutexLock.h"
 6 #include <pthread.h>
 7
 8 class Condition:NonCopyable //私有继承
 9 {
10     public:
11         Condition(MutexLock &mutex);
12         ~Condition();
13
14         void wait();//等待
15         void signal();//发送信号
16     private:
17         pthread_cond_t cond_;
18         MutexLock &mutex_; //wait函数的参数
19 };
20
21 Condition::Condition(MutexLock &mutex)
22     :mutex_(mutex)
23 {
24     pthread_cond_init(&cond_, NULL);
25 }
26
27 Condition::~Condition()
28 {
29     pthread_cond_destroy(&cond_);
30 }
31
32 void Condition::wait()
33 {
34     pthread_mutex_t  lock = mutex_.getMutex();
35     pthread_cond_wait(&cond_, &lock);
36 }
37
38 void Condition::signal()
39 {
40     pthread_cond_signal(&cond_);
41 }
42 #endif

这里要注意几点：

1）、wait必须在加锁的条件下方可使用；

2）、signal函数 一次唤醒一个线程，通常用来通知资源可用；

3）、broadcast函数一次通知多个线程，用来通知状态的改变，滥用其，将会导致“惊群”问题；

使用wait函数时，必须使用while 循环。原因如下：

1、采用 if 语句，最多只能判断一次；

2、为了描述方便，我们假设，这里有 5 个生产者（producer）， 3 个消费者（consumer），缓冲区中最多能盛放 10 个产品；

a）假设现在缓冲区中已经存在10 个产品，如果再用生产者A抢到这把锁，就会调用 wait函数， 将producer函数阻塞，向consumer发送信号并释放该锁，

b）这时有一个consumer抢到 该锁，自然会消费一个产品，并释放该 锁，这时产品数还有 9 个；

c）由于抢锁 是不排队的，因此有可能是除了 A 之外的 producer（假设为B） 抢到锁，由于缓冲区未满（9个），因此会生产一个产品，这时缓冲区已满；

d）还是由于 抢锁是不排队的，这时有可能 A 又重新获得该锁，由于 if 只会判断一次， 而且也已近执行过，故，A生产者会生产一个产品，由于缓冲区已满，

这时如果再生产产品的话，就会造成溢出。

e）若采用 whilt 循环， A 若获得该锁，则会先判断 缓冲区的状态（是否已满），如果已满，则又会进入阻塞状态，不会造成溢出。

3、为了防止broadcast的干扰：如果有且仅有一个资源，使用broadcast会唤醒所有等待的线程，那么多个线程被唤醒，但最终只有一个能拿到资源，这就是所谓的“惊群效应”。