pthread_cond_wait()理解

條件變量
條件變量是線程可用的另一種同步機制，條件標量給多個線程提供了一種會合的場所，條件變量和互斥所一起使用，允許線程一無競爭的方式等待特定的條件發生。條件變量本身是需要互斥鎖進行保護的，線程在改變條件狀態前必須首先鎖住互斥量，其他線程在獲得互斥兩之前不會察覺到這種改變，因為必須鎖住互斥量才能計算出條件！
opthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)函數傳入的參數mutex用於保護條件，因為我們在調用pthread_cond_wait時，如果條件不成立我們就進入阻塞，但是進入阻塞這個期間，如果條件變量改變了的話，那我們就漏掉了這個條件。因為這個線程還沒有放到等待隊列上，所以調用pthread_cond_wait前要先鎖互斥量，即調用pthread_mutex_lock(),pthread_cond_wait在把線程放進阻塞隊列後，自動對mutex進行解鎖，使得其它線程可以獲得加鎖的權利。這樣其它線程才能對臨界資源進行訪問並在適當的時候喚醒這個阻塞的進程。當pthread_cond_wait返回的時候又自動給mutex加鎖。
o函數使用過程如下：
       /************pthread_cond_wait()的使用方法**********/
      pthread_mutex_lock(&qlock);    /*lock*/
      pthread_cond_wait(&qready, &qlock); /*block-->unlock-->wait() return-->lock*/
      pthread_mutex_unlock(&qlock); /*unlock*/
      /*****************************************************/
 
 下面是具體例子

 
#include <pthread.h>  
#include <stdio.h>  
#include <stdlib.h>   
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;/*初始化互斥鎖*/  
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;/*初始化條件變量*/  
void *thread1(void *);  
void *thread2(void *);  
int i=1;  
int main(void)  
{  
    pthread_t t_a;  
    pthread_t t_b;  
    pthread_create(&t_a,NULL,thread1,(void *)NULL);/*創建進程t_a*/  
    pthread_create(&t_b,NULL,thread2,(void *)NULL); /*創建進程t_b*/  
    pthread_join(t_a, NULL);/*等待進程t_a結束*/  
    pthread_join(t_b, NULL);/*等待進程t_b結束*/  
    pthread_mutex_destroy(&mutex);  
    pthread_cond_destroy(&cond);  
    exit(0);  
}  
void *thread1(void *junk)  
{  
    for(i=1;i<=6;i++)  
    {  
        pthread_mutex_lock(&mutex);/*鎖住互斥量*/  
        printf("thread1: lock %d/n", __LINE__);  
        if(i%3==0){  
            printf("thread1:signal 1  %d/n", __LINE__);  
            pthread_cond_signal(&cond);/*條件改變，發送信號，通知t_b進程*/  
            printf("thread1:signal 2  %d/n", __LINE__);  
            sleep(1);  
        }  
        pthread_mutex_unlock(&mutex);/*解鎖互斥量*/  
        printf("thread1: unlock %d/n/n", __LINE__);  
        sleep(1);  
    }  
}  
void *thread2(void *junk)  
{  
    while(i<6)  
    {  
        pthread_mutex_lock(&mutex);  
        printf("thread2: lock %d/n", __LINE__);  
        if(i%3!=0){  
            printf("thread2: wait 1  %d/n", __LINE__);  
            pthread_cond_wait(&cond,&mutex);/*解鎖mutex，並等待cond改變*/  
            printf("thread2: wait 2  %d/n", __LINE__);  
        }  
        pthread_mutex_unlock(&mutex);  
        printf("thread2: unlock %d/n/n", __LINE__);  
        sleep(1);  
    }  
}