條件變量

條件變量必須與互斥鎖一起連用，條件變量中的線程不會主動醒來，而是要等待別的線程喚醒條件變量。
條件變量的函數接口

1）初始化一個條件變量
pthread_cond_init()
動態初始化：

ond：未初始化的條件變量的地址 pthread_cond_t 條件變量的地址類型
attr：屬性 普通屬性NULL
失敗返回錯誤碼

靜態初始化： pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

2）進入條件變量中進行等待
pthread_cond_wait()
如果滿足進入條件變量中等待，則進入之前默認自動解鎖。

cond： 已經初始化過的條件變量
mutex：已經在上鎖狀態的互斥鎖的地址

失敗返回錯誤碼

3）喚醒條件變量中的等待的線程
廣播： 喚醒條件變量中所有的線程 pthread_cond_broadcast()
單播： 隨機喚醒條件變量中的一個線程 pthread_cond_signal()

cond： 已經初始化的條件變量
失敗返回錯誤碼

4）銷毀條件變量
pthread_cond_destroy()
cond： 已經初始化的條件變量
失敗返回錯誤碼

pthread_mutex_t m = PTHREAD_MUTEX_INITIALIZER;  
pthread_cond_t v = PTHREAD_COND_INITIALIZER;

int sum = 400;

//線程任務：-200
void *routine(void *arg)
{
	//在訪問之前，首先要先上鎖
	pthread_mutex_lock(&m);
	
	while(sum < 200)  //這里不能使用if,因為醒來之后還需要判斷sum是否小于200
	{
		//則進入條件變量中等待
		pthread_cond_wait(&v,&m);  //自動解鎖，進入條件變量v中睡覺！
	}
	
	//從循環出來： 一定是被喚醒并且是>=200
	printf("before money:%d\n",sum);
	sum -= 200;
	printf("after money:%d\n",sum);
	
	pthread_mutex_unlock(&m); //解鎖
	
	pthread_exit(NULL);//結束
}

void *time_fun(void *arg)
{
	int i = 0;
	while(1)
	{
		printf("%d\n",i++);
		sleep(1);
	}
}

int main()
{
	pthread_t tid_test;
	pthread_create(&tid_test,NULL,time_fun,NULL);
	
	pthread_t tid[5]; //存放5個子線程的ID  下標：0~4
	int i;
	
	for(i=0;i<5;i++)
	{
		pthread_create(&tid[i],NULL,routine,NULL);
	}
	
	sleep(3);  //2個運行，3個在睡覺
	pthread_mutex_lock(&m);
	sum += 200;
	printf("parent + 200!\n");
	pthread_mutex_unlock(&m);
	
	sleep(5);
	
	pthread_cond_broadcast(&v);// 喚醒條件變量中3個正在睡覺的
	printf("broadcast!\n");
	
	sleep(2);
	
	pthread_mutex_lock(&m);
	sum += 400;
	printf("parent + 400!\n");
	pthread_mutex_unlock(&m);
	
	pthread_cond_signal(&v);
	printf("signal!\n");
	
	sleep(5);
	
	pthread_cond_signal(&v);
	printf("signal!\n");
	
	for(i=0;i<5;i++)
	{
		pthread_join(tid[i],NULL);
	}
	
	pthread_mutex_destroy(&m);
	pthread_cond_destroy(&v);
	
	return 0;

}