我正在编码以模拟卖票情况:
两个线程一张一张卖票,一个线程当票数为0时显示sold out
。
所以我尝试使用条件变量。代码如下:
int a = 10;
pthread_mutex_t mtx;
pthread_cond_t cond;
void * funca(void *p)
{
while(1)
{
pthread_mutex_lock(&mtx);
if (a == 0)
{
break;
}
a--;
pthread_mutex_unlock(&mtx);
sleep(1);
}
pthread_mutex_unlock(&mtx);
pthread_cond_broadcast(&cond);
return NULL;
}
void * funcb(void *p)
{
while(1)
{
pthread_mutex_lock(&mtx);
if (a == 0)
{
break;
}
a--;
pthread_mutex_unlock(&mtx);
sleep(1);
}
pthread_mutex_unlock(&mtx);
pthread_cond_broadcast(&cond);
return NULL;
}
void * funcc(void *p)
{
pthread_mutex_lock(&mtx);
while(a != 0)
{
pthread_cond_wait(&cond, &mtx);
printf("I'm nothing");
}
pthread_mutex_unlock(&mtx);
printf("sold out\n");
return NULL;
}
但是,当我执行上面的代码时,我得到了一个无限循环,其中打印了许多 I'm nothing
。
最佳答案
您还没有初始化互斥量和条件变量。声明变量时,请使用:
pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
funca()
和 funcb()
有两个相同的函数也没有意义,您可以让两个不同的线程执行相同的函数。
关于c - 为什么 pthread 条件变量不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41175454/