多线程条件变量

Question

我正在研究哲学家进餐问题，n位哲学家轮流思考和进餐。我想有一个版本，哲学家们会按照id的顺序进食：0,1,2,3,4。。。，但是我的线程一直被阻塞。我的线程从调用PhilosopherThread开始。

void putDownChopsticks(int threadIndex){
     //finished eating
     pindex++;
     pthread_cond_signal(&cond);
     pthread_mutex_unlock(&lock);
}

void pickUpChopsticks(int threadIndex){
     pthread_mutex_lock(&lock);
     while(pindex != threadIndex){
         pthread_cond_wait(&cond, &lock);
     } 
     //lets go eat
} 

void eating(){
     //put thread to sleep
}

void thinking(){
     //put thread to sleep
}

void* PhilosopherThread(void *x){
     int *index = x;
     thinking(); //just puts thread to sleep to simulate thinking
     pickUpChopsticks(*index);
     eating(); //just puts thread to sleep to simulate eating
     putDownChopsticks(*index);
     return NULL;
}

我想把哲学家们整理好有点麻烦。我只能在线程堵塞之前吃前2个线程。

编辑：据我所知，我这样做是对的。我首先锁定互斥锁，然后检查pindex是否是当前线程id，如果不是，线程将等待，直到pindex等于id。然后线程可以去吃，一旦完成，我们增加pindex，发出线程完成的信号，并解锁互斥锁。

Answer 1

此代码有时有效，有时无效。首先，由于您没有提供完整的程序，以下是我用于测试目的的缺失位：

#include <stdlib.h>
#include <pthread.h>

static pthread_cond_t cond;
static pthread_mutex_t lock;
static pindex;

/* ... your code ... */

int main () {
    int id[5], i;
    pthread_t tid[5];
    for (i = 0; i < 5; ++i) {
        id[i] = i;
        pthread_create(tid+i, 0, PhilosopherThread, id+i);
    }
    for (i = 0; i < 5; ++i) pthread_join(tid[i], 0);
    exit(0);
}

要注意的关键部分是你如何唤醒下一个哲学家：

 pthread_cond_signal(&cond);

此调用只会唤醒一个线程。但是，哪个线程由操作系统决定。因此，如果它没有唤醒应该醒来的哲学家，就没有其他哲学家被唤醒。

一个简单的解决方法是唤醒所有等待的线程，而不是只唤醒一个线程。不匹配的哲学家会回到等待中去，下一个应该去的哲学家会去。

 pthread_cond_broadcast(&cond);

然而，由于每个线程都知道应该唤醒哪个哲学家，所以您可以更改您的解决方案以允许这种情况发生。一种方法是为每个哲学家实现一个单独的条件变量，并对下一个哲学家的条件变量使用pthread\u cond\u signal（）。