为什么 pthread 条件变量不起作用

Question

我正在编写代码以模拟卖票情况：
两个线程一张一张卖票，一个线程在票数为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。

Answer 1

您还没有初始化互斥量和条件变量。声明变量时，使用：

pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

funca() 和 funcb() 有两个相同的函数也没有意义，你可以让两个不同的线程执行相同的函数。

为什么 pthread 条件变量不起作用

Why doesn't the pthread condition variable work

c

multithreading

mutex

pthreads

race-condition