Linux组件封装(二) 条件变量Condition的封装

声明代码如下:

#ifndef CONDITION_H
#define CONDITION_H

#include <pthread.h>
#include "NonCopyable.h"

class MutexLock;


class Condition : NonCopyable
{
public:
    Condition(MutexLock &mutex);
    ~Condition();

    void wait();
    void notify();
    void notifyAll();
private:
    pthread_cond_t _cond;
    MutexLock &_mutex;
};

#endif

需要注意:

1.wait必须在加锁条件下调用

2.notify一次唤醒一个线程，通常用来通知资源可用

3.notifyAll一次通知多个线程，通常用来通知状态的变化。滥用broadcast会导致"惊群"问题。

使用wait必须采用while判断，原因在于:

1.如果采用if，最多判断一次

2.线程A等待数据，阻塞在full上，那么当另一个线程放入产品时，通知A去拿数据，此时另一个线程B抢到锁，直接进入临界区，取走资源。A重新抢到锁，（因为采用的是if，所以不会判断第二次）进去临界区时，已经没有资源。

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

cpp代码实现如下：

#include "Condition.h"
#include "MutexLock.h"
#include <assert.h>

Condition::Condition(MutexLock &mutex)
    :_mutex(mutex)
{
    TINY_CHECK(!pthread_cond_init(&_cond, NULL));
}

Condition::~Condition()
{
    TINY_CHECK(!pthread_cond_destroy(&_cond));
}

void Condition::wait()
{
    assert(_mutex.isLocked());
    TINY_CHECK(!pthread_cond_wait(&_cond, _mutex.getMutexPtr()));
    _mutex.restoreMutexStatus();
}

void Condition::notify()
{
    TINY_CHECK(!pthread_cond_signal(&_cond));
}

void Condition::notifyAll()
{
    TINY_CHECK(!pthread_cond_broadcast(&_cond));
}