c - 为什么 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() 有两个相同的函数也没有意义，您可以让两个不同的线程执行相同的函数。