名称：

pthread_cond_init

功能：

initialize condition variables  初始化条件变量

头文件：

#include <pthread.h>

函数原形：

int pthread_cond_init(pthread_cond_t *restrict cond,

const pthread_condattr_t *restrict attr);

参数：

返回值：

the pthread_cond_destroy() and pthread_cond_init() functions shall return zero; otherwise, an error number shall be returned to indicate the error

名称：

pthread_cond_destroy

功能：

Destroy condition variables  销毁条件变量

头文件：

#include <pthread.h>

函数原形：

int pthread_cond_destroy(pthread_cond_t *cond);

参数：

函数说明：

在释放或废弃条件变量之前，需要毁坏它，使用此函数

返回值：

the pthread_cond_destroy() and pthread_cond_init() functions shall return zero; otherwise, an error number shall be returned to indicate the error

名称：

pthread_cond_wait

功能：

Wait on a condition，等待某个条件是否成立。对于timewait()函数除了等待以外，可以设置一个时长。

头文件：

#include <pthread.h>

函数原形：

intpthread_cond_wait(pthread_cond_t *restrict cond,pthread_mutex_t *restrict mutex);

参数：

函数说明：

一旦初始化了互斥对象和条件变量，就可以等待这个条件，一个特定条件只能有一个互斥对象，而且条件变量应该表示互斥数据“内部”的一种特殊的条件更改。一个互斥条件可以用许多条件变量（例如：cond_empty,cond_full,cond_cleanup）,但每个条件变量只能有一个互斥对象。

返回值：

名称：

pthread_cond_signal

功能：

signal a condition，这种情况是只有一个线程收到后执行动作。

头文件：

#include <pthread.h>

函数原形：

int pthread_cond_signal(pthread_cond_t *cond);

参数：

函数说明：

活动线程只需要唤醒第一个正在睡眠的线程。假设您只对队列添加了一个工作作业。那么只需要唤醒一个工作程序线程（再唤醒其它线程是不礼貌的！）

返回值：

名称：

pthread_cond_broadcast

功能：

broadcast a condition，通过广播的形式发给子线程消息，子线程竞争执行。

头文件：

#include <pthread.h>

函数原形：

int pthread_cond_broadcast(pthread_cond_t *cond);

参数：

函数说明：

如果线程更改某些共享数据，而且它想要唤醒所有正在等待的线程，则应使用 pthread_cond_broadcast调用

返回值：

#include <stdlib.h>

#include <pthread.h>

#include <stdio.h>

#include <unistd.h>

struct msg {

struct msg *next;

int num;

};

struct msg *head;

/*条件变量 */

pthread_cond_t has_product = PTHREAD_COND_INITIALIZER;

pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;

void *consumer(void *p)

{

struct msg *mp;

for (;;) {

pthread_mutex_lock(&lock);

/* pthread_cond_wait(&has_product, &lock);

* 1.阻塞等待has_product被唤醒，

* 2.释放互斥锁， pthread_mutex_unlock(&lock)

* 3.当被唤醒时，解除阻塞，并且重新去申请获得互斥锁 pthread_mutex_lock(&lock)

*/

while (head == NULL)

pthread_cond_wait(&has_product, &lock);

mp = head;

head = mp->next;

pthread_mutex_unlock(&lock);

printf("Consume %d\n", mp->num);

free(mp);

sleep(rand() % 5);

}

}

void *producer(void *p)

{

struct msg *mp;

for (;;) {

mp = (struct msg *)malloc(sizeof(struct msg));

mp->num = rand() % 1000 + 1;

printf("Produce %d\n", mp->num);

pthread_mutex_lock(&lock);

mp->next = head;

head = mp;

pthread_mutex_unlock(&lock);

/* pthread_cond_broadcast(&has_product)唤醒等待队列上的所有线程*/

//发送信号，告诉消费者有产品了

pthread_cond_signal(&has_product);

sleep(rand() % 5);

}

}

int main(int argc, char *argv[])

{

pthread_t pid, cid;

srand(time(NULL));

pthread_create(&pid, NULL, producer, NULL);

pthread_create(&cid, NULL, consumer, NULL);

pthread_join(pid, NULL);

pthread_join(cid, NULL);

return 0;

}