pthread_cond_broadcast 不起作用？

Question

我写了这个程序：

pthread_cond_t placeFootCondition;

pthread_mutex_t rf,lf;

void* rss(void* in){
    while(1){
        pthread_mutex_lock(&rf);
        printf ( "rss: waiting for condition\n" );
        pthread_cond_wait(&placeFootCondition,&rf);
        printf ( "                  Right Single Support \n" );
        sleep(1);
        pthread_mutex_unlock(&rf);

    }
}

void* lss(void* in){
    while(1){
        pthread_mutex_lock(&lf);
        printf ( "lss: waiting for condition\n" );
        pthread_cond_wait(&placeFootCondition,&lf);
        printf ( "Left Single Support \n" );
        sleep(1);
        pthread_mutex_unlock(&lf);

    } 
}


int main(){
    int rc;
    pthread_mutex_init(&rf,NULL);
    pthread_mutex_init(&lf,NULL);
    pthread_cond_init(&placeFootCondition,NULL);
    pthread_create(&t1,NULL,rss,NULL);
    pthread_create(&t2,NULL,lss,NULL);
    sleep(1);
    rc=pthread_cond_broadcast(&placeFootCondition);
    if(rc!=0) printf ( "rc=%i\n",rc );
    sleep(5);
}

但是程序的输出是

rss: waiting for condition
lss: waiting for condition
              Right Single Support 
rss: waiting for condition

pthread_cond_broadcast(&placeFootCondition) 不应该唤醒所有线程？？？

Answer 1

这就是你正在做的事情：

pthread_cond_wait(&placeFootCondition,&rf); /* First thread uses rf mutex. */

pthread_cond_wait(&placeFootCondition,&lf); /* Second thread uses lf mutex. */

这是标准关于使用的内容不同的互斥锁：

当线程等待条件变量时，已指定
pthread_cond_timedwait() 或 pthread_cond_timedwait() 的特定互斥体
pthread_cond_wait()操作，之间形成动态绑定
互斥锁和条件变量只要在
至少有一个线程被条件变量阻塞。在此期间
时间，任何线程尝试等待该条件的效果
使用不同互斥体的变量未定义。

---

最重要的是，在等待条件变量时，每个线程都应该使用相同的互斥锁。

Answer 2

除了不正确地使用不同的互斥体之外，您的程序也不遵循任何逻辑。条件变量表示什么条件？ （这称为“谓词”。）如果没有谓词，您将迷失唤醒。

pthread_cond_wait 函数尽管有其名称，但它并不是一个条件等待。这是无条件等待某个条件。仅当需要等待条件时才必须调用它。

假设你和你姐姐共用一辆车，而你姐姐借了车，你就不能使用这辆车，所以你等着你姐姐回家。好吧，如果她已经回家了，你就要等很长时间了！ （如果她回家了，但当你到达车旁时，她和车都不见了，你必须再次等待。）

模式是（对于你）：

// let's get the car
pthread_mutex_lock(&mutex_that_protects_car);
while(car==SISTER_HAS_CAR) // car is gone
 pthread_mutex_wait(&condition_variable, &mutex_that_protects_car);
car=BROTHER_HAS_CAR; // it's my car now
pthread_mutex_unlock(&mutex_that_protects_car);
// we now have the car

对于你的妹妹：

// we are done with the car, make it free
pthread_mutex_lock(&mutex_that_protects_car);
car=CAR_IS_FREE;
pthread_cond_broadcast(&condition_variable); // he can have the car
pthread_mutex_unlock(&mutex_that_protects_car);

请注意，必须保护汽车的状况由单个共享互斥体。汽车的状态是谓词，它受互斥体保护并由线程共享。

另请注意，我们在且仅当等待条件时才调用 pthread_cond_wait。当汽车空闲时，我们不会等待。我们一直在等待，以防她在我们抢到车之前再次抢到车。