條件變數   

  條件變數是利用執行緒間共享的全域性變數進行同步的一種機制，主要包括兩個動作：一個執行緒等待"條件變數的條件成立"而掛起；另一個執行緒使"條件成立"（給出條件成立訊號）。為了防止競爭，條件變數的使用總是和一個互斥鎖結合在一起。  

條件變數是利用執行緒間共享的全域性變數進行同步的一種機制，主要包括兩個動作：
1）一個執行緒等待"條件變數的條件成立"而掛起；
2）另一個執行緒使"條件成立"（給出條件成立訊號）。
為了防止競爭，條件變數的使用總是和一個互斥鎖結合在一起。

1.主要涉及到下面的函式：
int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr) ---動態建立條件變數

pthread_mutex_lock ---互斥鎖上鎖

pthread_mutex_unlock ----互斥鎖解鎖

pthread_cond_wait() / pthread_cond_timedwait -----等待條件變數，掛起執行緒，區別是後者，會有timeout時間，如 果到了timeout,執行緒自動解除阻塞，這個時間和 time()系統呼叫相同意義的。以1970年時間算起。

pthread_cond_signal ----啟用等待列表中的執行緒，

pthread_cond_broadcast() -------啟用所有等待執行緒列表中最先入隊的執行緒

注意：1）上面這幾個函式都是原子操作，可以為理解為一條指令，不會被其他程式打斷
           2）上面這個幾個函式，必須配合使用。

           3）pthread_cond_wait，先會解除當前執行緒的互斥鎖，然後掛線執行緒，等待條件變數滿足條件。一旦條件變                   量滿足條件，則會給執行緒上鎖，繼續執行pthread_cond_wait

2. 程式碼例項
編譯：gcc thread_test.c -o thread_test -lpthread
------必須加上-lpthread，不然會報錯，找不到執行緒的相關函式，gcc自身沒有連線執行緒

#include<pthread.h>
#include<unistd.h>
#include<stdio.h>
#include<stdlib.h>
 
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;/*初始化互斥鎖*/
pthread_cond_t  cond = PTHREAD_COND_INITIALIZER;//init cond
 
void *thread1(void*);
void *thread2(void*);
 
int i = 1; //global
 
int main(void){
    pthread_t t_a;
    pthread_t t_b;//two thread
 
    pthread_create(&t_a,NULL,thread2,(void*)NULL);
    pthread_create(&t_b,NULL,thread1,(void*)NULL);//Create thread
    
    printf("t_a:0x%x, t_b:0x%x:", t_a, t_b);
    pthread_join(t_b,NULL);//wait a_b thread end
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
   exit(0);
}
 
void *thread1(void *junk){
    for(i = 1;i<= 9; i++){
        pthread_mutex_lock(&mutex); //互斥鎖
        printf("call thread1 \n");
        if(i%3 == 0)
        	{
            pthread_cond_signal(&cond); //send sianal to t_b
            printf("thread1:******i=%d\n", i);
        	}
        else
            printf("thread1: %d\n",i);
        pthread_mutex_unlock(&mutex);
 
		printf("thread1: sleep i=%d\n", i);
        sleep(1);
		printf("thread1: sleep i=%d******end\n", i);
    }
}
 
void *thread2(void*junk){
    while(i < 9)
    {
        pthread_mutex_lock(&mutex);
        printf("call thread2 \n");
        if(i%3 != 0)
            pthread_cond_wait(&cond,&mutex); //wait
         printf("thread2: %d\n",i);
        pthread_mutex_unlock(&mutex);
 
		printf("thread2: sleep i=%d\n", i);
        sleep(1);
		printf("thread2: sleep i=%d******end\n", i);		
    }
}                                    
 

執行結果

[[email protected] test]$ ./thread_test
call thread2 
t_a:0xb76f6b70, t_b:0xb6cf5b70:call thread1 
thread1: 1
thread1: sleep i=1
thread1: sleep i=1******end
call thread1 
thread1: 2
thread1: sleep i=2
thread1: sleep i=2******end
call thread1 
thread1:******i=3
thread1: sleep i=3
thread2: 3
thread2: sleep i=3
thread1: sleep i=3******end
call thread1 
thread1: 4
thread1: sleep i=4
thread2: sleep i=4******end
call thread2 
thread1: sleep i=4******end
call thread1 
thread1: 5
thread1: sleep i=5
thread1: sleep i=5******end
call thread1 
thread1:******i=6
thread1: sleep i=6
thread2: 6
thread2: sleep i=6
thread1: sleep i=6******end
call thread1 
thread1: 7
thread1: sleep i=7
thread2: sleep i=7******end
call thread2 
thread1: sleep i=7******end
call thread1 
thread1: 8
thread1: sleep i=8
thread1: sleep i=8******end
call thread1 
thread1:******i=9
thread1: sleep i=9
thread2: 9
thread2: sleep i=9
thread1: sleep i=9******end
[[email protected] test]$ 

轉載至https://blog.csdn.net/u012109245/article/details/38662371