（4）条件变量

条件变量

定义：  pthread_cond_t

初始化：PTHREAD_COND_INITIALIZER    //只限于使用在静态分配条件变量

1． pthread_cond_init（）  但要调用 pthread_mutex_destroy 释放

 

#include

2． int pthread_cond_init(pthread_cond_t *restrict cond,pthread_condattr_t *restrict attr);

3． int pthread_cond_destroy(pthread_cond_t *cond);

Both return: 0 if OK, error number on failure

 

等待条件为真：

#include

4． int pthread_cond_wait(pthread_cond_t *restrict cond,pthread_mutex_t *restrict mutex);

5． int pthread_cond_timedwait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex,

const struct timespec *restrict timeout);

返回值：成功返回0， 否则返回错误编号

  第一个函数，先lock，接着等待条件，然后unlock。

  第二个函数，多了时间限制，如果超过时限后条件还没发生，函数将再次请求mutex，并且然后ETIMEDOUT错误.

  时间限制使用下面这个结构体：

   struct timespec {

        time_t tv_sec;   /* seconds */

        long   tv_nsec;  /* nanoseconds */十亿分之一秒，毫微秒

     };

  时间限制是绝对值，所以要把相对时间转为绝对时间：

  void maketimeout(struct timespec *tsp, long minutes)

  {

     struct timeval now;

 

gettimeofday(&now);/*取得当前时间*/

     tsp->tv_sec = now.tv_sec;

     tsp->tv_nsec = now.tv_usec * 1000; /* usec to nsec */

tsp->tv_sec += minutes * 60;

   }

 

当条件满足时，使用下面两个函数之一来唤醒线程

#include

6． int pthread_cond_signal(pthread_cond_t *cond);        //唤醒等待该条件的某个线程

7． int pthread_cond_broadcast(pthread_cond_t *cond);     //唤醒等待该条件的所以线程

Both return: 0 if OK, error number on failure

 

********************************************************************

举例说明线程中的条件变量的使用

*********************************************************************

#include

#include

#include

 

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

pthread_cond_t cond   = PTHREAD_COND_INITIALIZER;

int i=1;

 

void *thread1(void *junk)

{

    for(i=1;i<=9;i++)

    {

        pthread_mutex_lock(&mutex);

        if(i%3==0)

             pthread_cond_signal(&cond);

        else                

             printf("thead1:%d\n",i);

        pthread_mutex_unlock(&mutex);

        sleep(1);

    }

}

 

void *thread2(void *junk)

{

    while(i<=9)

    {

        pthread_mutex_lock(&mutex);

        if(i%3!=0)

            pthread_cond_wait(&cond,&mutex);

        printf("thread2:%d\n",i);

        pthread_mutex_unlock(&mutex);

        sleep(1);

    }

}

 

int main(void)

{

    pthread_t t_a;

    pthread_t t_b;

 

    pthread_create(&t_a,NULL,thread2,(void *)NULL);

    pthread_create(&t_b,NULL,thread1,(void *)NULL);

    pthread_join(t_b, NULL);

    pthread_mutex_destroy(&mutex);     

    pthread_cond_destroy(&cond);

    exit(0);

}

结果：

thead1:1

thead1:2

thread2:3

thead1:4

thead1:5

thread2:6

thead1:7

thead1:8

thread2:9

*********************************************************************