Linux线程同步：条件变量

条件变量通过允许线程阻塞和等待另一个线程发送信号的方法弥补了互斥锁的不足，它常和互斥锁一起使用。使用时，条件变量被用来阻塞一个线程，当条件不满足时，线程往往解开相应的互斥锁并等待条件发生变化。一旦其它的某个线程改变了条件变量，它将通知相应的条件变量唤醒一个或多个正被此条件变量阻塞的线程。这些线程将重新锁定互斥锁并重新测试条件是否满足。一般说来，条件变量被用来进行线承间的同步。

1、条件变量的结构为 pthread_cond_t （相当于windows中的事件的作用）

2、条件变量的初始化

int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr);  

其中 cond 是一个指向结构 pthread_cond_t 的指针，cond_attr 是一个指向结构 pthread_condattr_t 的指针。结构 pthread_condattr_t 是条件变量的属性结构，和互斥锁一样我们可以用它来设置条件变量是进程内可用还是进程间可用，默认值是 PTHREAD_ PROCESS_PRIVATE，即此条件变量被同一进程内的各个线程使用。注意初始化条件变量只有未被使用时才能重新初始化或被释放。

3、条件变量的释放

释放一个条件变量的函数为

int pthread_cond_destroy(pthread_cond_t *cond); 

4、条件变量的等待

（1）函数 pthread_cond_wait() 使线程阻塞在一个条件变量上。它的函数原型为：　　

int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);

线程解开mutex指向的锁并被条件变量cond阻塞。线程可以被函数 pthread_cond_signal 和函数 pthread_cond_broadcast 唤醒，但是要注意的是，条件变量只是起阻塞和唤醒线程的作用，具体的判断条件还需用户给出，例如一个变量是否为0等等，这一点我们从后面的例子中可以看到。线程被唤醒后，它将重新检查判断条件是否满足，如果还不满足，一般说来线程应该仍阻塞在这里，被等待被下一次唤醒。这个过程一般用 while语句 实现。

（2）另一个用来阻塞线程的函数是 pthread_cond_timedwait()，它的原型为：

int pthread_cond_timewait(pthread_cond_t *cond, pthread_mutex *mutex, const timespec *abstime);

它比函数pthread_cond_wait（）多了一个时间参数，经历abstime段时间后，即使条件变量不满足，阻塞也被解除。

5、条件变量的解除改变

函数 pthread_cond_signal() 的原型为：

int pthread_cond_signal(pthread_cond_t *cond);

它用来释放被阻塞在条件变量cond上的一个线程。多个线程阻塞在此条件变量上时，哪一个线程被唤醒是由线程的调度策略  所决定的。要注意的是，必须用保护条件变量的互斥锁来保护这个函数，否则条件满足信号又可能在测试条件和调用 pthread_cond_wait 函数之间被发出，从而造成无限制的等待。

6、下面是使用函数 pthread_cond_wait() 和函数 pthread_cond_signal() 的一个简单的例子。

count值为 0 时，decrement函数在 pthread_cond_wait 处被阻塞，并打开互斥锁 count_lock。此时，当调用到函数 increment_count 时，pthread_cond_signal() 函数改变条件变量，告知decrement_count() 停止阻塞。

# 以下是 伪代码 #

pthread_mutex_t count_lock;
pthread_cond_t count_nonzero;
unsigned count;

decrement_count() 
{
	pthread_mutex_lock(&count_lock);
	while (count == 0)
	{
		pthread_cond_wait(&count_nonzero, &count_lock);
	}
	count = count -1;
	pthread_mutex_unlock(&count_lock);
}

increment_count()
{
	pthread_mutex_lock(&count_lock);
	if (count == 0)
	{
		pthread_cond_signal(&count_nonzero);	
	}
	count = count + 1;
	pthread_mutex_unlock(&count_lock);
}

count 值为 0 时，decrement 函数在 pthread_cond_wait 处被阻塞，并打开互斥锁 count_lock。此时，当调用到函数 increment_count 时，pthread_cond_signal() 函数改变条件变量，告知decrement_count() 停止阻塞。

参考：

http://www.cnblogs.com/feisky/archive/2010/03/08/1680950.html

http://blog.csdn.net/dai_weitao/article/details/1754964