如何让线程等待其他线程？线程14等待逻辑的代码故障排查

让我来帮你排查下这段代码里的几个关键问题，它们正是导致逻辑不符合预期的原因：

1. 条件变量的等待逻辑完全写反了 #

线程14里的while(release_T14) pthread_cond_wait(...)完全违背了你的需求：你想要的是当release_T14为0时让线程14暂停等待，直到它被设为1才继续执行。但当前代码的逻辑是「只要release_T14为1就进入等待」，这会导致两种错误结果：

• 如果release_T14初始为0，线程14会直接跳过等待，完全达不到暂停的目的；
• 如果release_T14被设为1，线程14会陷入无限等待无法退出。

正确的写法应该是：

while(!release_T14) pthread_cond_wait(s->cond, s->lock);

2. 共享变量的访问缺乏同步保护 #

多个线程共享的has_T14_started、thread_count变量，在修改和读取时都没有被互斥锁正确保护：

• 线程14设置has_T14_started = 1时，其他线程可能同时读取这个变量，引发竞态条件——比如多个非14线程同时看到has_T14_started为1，同时进入临界区修改thread_count，导致计数错误；
• thread_count初始值设为1的逻辑模糊，且非14线程只有在has_T14_started为1时才会增加计数，这可能导致thread_count永远达不到5（比如线程14还没启动，其他线程都不会去更新计数）。

3. 线程启动顺序的不确定性 #

pthread_create只是触发线程创建，但线程的实际执行顺序由操作系统调度决定，你无法保证线程14会在其他4个线程之前启动。如果其他线程先执行，它们会看到has_T14_started为0，不会去增加thread_count，最终导致release_T14永远不会被设为1，线程14陷入永久等待。

4. 重置has_T14_started的时机错误 #

当thread_count == 5时你把has_T14_started设为0，这会导致后续启动的非14线程不再更新thread_count，但你的需求是确保线程14在包含自身在内的5个线程运行前不结束，这个逻辑完全没有覆盖后续线程的情况。

下面是调整后的代码，修复了上述所有问题：

#include <pthread.h>

typedef struct { 
    int id; 
    pthread_cond_t *cond; 
    pthread_mutex_t *lock; 
} thP2_struct;

// 所有共享变量必须在互斥锁保护下访问
int thread_count = 0;
int t14_is_waiting = 0;

void *P2_thread_function(void *arg) {
    thP2_struct *s = (thP2_struct *)arg;
    
    pthread_mutex_lock(s->lock);
    thread_count++; // 每个线程启动后立即增加运行计数
    
    if (s->id == 14) {
        t14_is_waiting = 1;
        // 等待直到包括自身在内的至少5个线程启动
        while (thread_count < 5) {
            pthread_cond_wait(s->cond, s->lock);
        }
        t14_is_waiting = 0;
    } else {
        // 如果线程14正在等待，且当前刚好凑够5个线程，唤醒它
        if (t14_is_waiting && thread_count == 5) {
            pthread_cond_signal(s->cond);
        }
    }
    pthread_mutex_unlock(s->lock);
    
    // 这里可以添加线程的业务逻辑
    
    return NULL;
}

void function(){
    pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
    pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
    pthread_t tid[40];
    thP2_struct data[40];
    
    for(int i = 0; i < 40; i++){
        data[i].id = i + 1;
        data[i].cond = &cond;
        data[i].lock = &lock;
        pthread_create(&tid[i], NULL, P2_thread_function, &data[i]);
    }
    
    for(int i = 0; i < 40; i++){
        pthread_join(tid[i], NULL);
    }
    
    pthread_cond_destroy(&cond);
    pthread_mutex_destroy(&lock);
}

修正点说明 #

• 所有共享变量的读写都被包裹在互斥锁的临界区内，彻底避免竞态条件；
• 线程14启动后直接检查当前运行线程数，不足5个就进入等待；
• 每个非14线程启动后，都会主动检查是否需要唤醒等待中的线程14；
• 去掉了冗余的release_T14变量，直接用thread_count >=5作为等待条件，逻辑更清晰直观。

内容的提问来源于stack exchange，提问作者Oros Tom