全域變數初始化為0, 兩個執行緒, 一個執行緒對它每次增1, 當大於等於100時, 給另一個執行緒發送條件. 重設為0
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
struct foo{
int f_count;
pthread_mutex_t f_lock;
pthread_cond_t f_cond;
};
/* 初始化互斥量与条件变量 */
struct foo * foo_alloc(){
struct foo *fp;
if((fp = malloc(sizeof(struct foo))) != NULL){
fp->f_count = 0;
pthread_mutex_init(&fp->f_lock, NULL);
pthread_cond_init(&fp->f_cond, NULL);
}
return fp;
}
/* 加法 */
void *foo_increase(void *arg){
struct foo *fp;
fp = (struct foo*)arg;
while(1){
pthread_mutex_lock(&fp->f_lock);
fp->f_count++;
/* 大于等于100时发送条件 */
if(fp->f_count >= 100){
pthread_cond_signal(&fp->f_cond);
}
pthread_mutex_unlock(&fp->f_lock);
}
}
/* 重新置0 */
void *foo_print(void *arg){
struct foo *fp;
fp = (struct foo*)arg;
while(1){
pthread_mutex_lock(&fp->f_lock);
while(fp->f_count < 100){
//释放掉锁, 等待条件为真返回, 再次锁住.
pthread_cond_wait(&fp->f_cond, &fp->f_lock);
}
printf("重置 : %d\n", fp->f_count);
/* 重新置0 */
fp->f_count = 0;
pthread_mutex_unlock(&fp->f_lock);
}
}
int main(void){
struct foo *fp;
pthread_t tid_increase1, tid_print;
//初始化
fp = foo_alloc();
//加法线程
pthread_create(&tid_increase1, NULL, foo_increase, fp);
//重置线程
pthread_create(&tid_print, NULL, foo_print, fp);
//防止主线程提前退出
sleep(20);
exit(0);
}
可是我在重置線程下打印出來為什麼是下面這個結果, 不應該是100嗎?
重置線程已經把互斥量給鎖住了, 但好像另一個線程仍然在不斷累加.
置0前 : 54
置0前 : 92
置0前 : 47
置0前 : 85
置0前 : 51
...