c++ - Pthread查询: Sequence of threads error

Question

#include<pthread.h>
#include<stdio.h>

int num_threads=3;

int state=0;

pthread_cond_t cond;

pthread_mutex_t mutex;

void* threadA(void* args) {

int i;
for(i=0; i<5; i++){ 
    pthread_mutex_lock(&mutex);

        while(state == 1 || state == 2) pthread_cond_wait(&cond,&mutex);

        printf("Thread A\n");
        state = (state+1)%num_threads;
        pthread_cond_signal(&cond);

    pthread_mutex_unlock(&mutex);
}
}

void* threadB(void* args) {

int i;
for(i=0; i<5; i++){ 
    pthread_mutex_lock(&mutex);

        while(state == 0 || state == 2)pthread_cond_wait(&cond,&mutex);

        printf("Thread B\n");
        state = (state+1)%num_threads;
        pthread_cond_signal(&cond);

    pthread_mutex_unlock(&mutex);
}
}

void* threadC(void* args) {

int i;
for(i=0; i<5; i++){ 
    pthread_mutex_lock(&mutex);

        while(state == 1 || state == 0) pthread_cond_wait(&cond,&mutex);

        printf("Thread C\n\n");
        state = (state+1)%num_threads;
        pthread_cond_signal(&cond);

    pthread_mutex_unlock(&mutex);
}
}


int main() {

pthread_t tid[3];

pthread_cond_init(&cond,NULL);
pthread_mutex_init(&mutex,NULL);

pthread_create(&tid[0],NULL,threadA,NULL);
pthread_create(&tid[1],NULL,threadB,NULL);      
pthread_create(&tid[2],NULL,threadC,NULL);

return 0;

问题:使用上面的代码，我想打印 threaA threadB threadC 依次执行 5 次。 但答案是不确定的。而订单 的线程被维护，答案不会被打印 5 次。 请帮忙!!!

Answer 1

正如@mch 在评论中提到的，在允许 main() 函数返回之前，您需要等待线程完成:

pthread_join(tid[0], NULL);
pthread_join(tid[1], NULL);
pthread_join(tid[2], NULL);

现在，将上面的连接添加到 main() 的末尾后，您的程序通常会挂起。发生这种情况是因为 pthread_cond_signal() 没有唤醒所有等待该条件变量的线程。如果唤醒了错误的线程(例如，threadC 发出条件信号，但收到通知的线程不是 threadA)，那么所有线程都将等待该条件，并且不会有人发出该条件信号。

要解决此问题，您需要确保每次都唤醒所有线程，并让每个线程自行决定是否轮到它(通过 while(state...) pthread_cond_wait(. ..);)。为此，您可以将对 pthread_cond_signal() 的调用替换为对 pthread_cond_broadcast() 的调用，这会取消阻塞当前在该条件下阻塞的所有 线程.