如何在barrier处正确同步pthread线程并解决循环结果收集的竞态问题

问题根因与解决方案 #

你的核心需求是保证每一轮的结果收集操作，必须在所有线程完成当前轮计算后、下一轮计算开始前执行完毕，同时要求必须使用barrier实现，现有方案的三个问题可以通过新增一次barrier同步来彻底解决：

原方案问题说明

1. 广播无法唤醒等待线程的核心原因是：执行收集的线程在发送广播后没有参与同步，直接进入下一轮计算，可能在其他线程被调度前就修改了共享状态，甚至触发下一轮的barrier等待，打乱了条件变量的同步时序；另外要确认你的互斥量、条件变量都完成了正确初始化。
2. 你的判断正确：while (thread_args->ready == 0)的判断可以覆盖广播发送后才到达等待点的线程场景，这类线程看到ready为1会直接跳过等待。
3. ready无法安全重置的核心是没有同步点保证所有线程都已经读取过ready=1的状态，贸然修改会导致部分线程读到旧值陷入永久等待。

修正后代码实现

利用pthread barrier可以自动重置、重复使用的特性，在收集完成后新增一次barrier同步，专门用来保证状态重置的安全性：

// 线程入口循环内的代码
while (running) {
    // 1. 每个线程执行当前轮的并行计算，操作自己负责的内存块
    doParallelWork(thread_args->my_block);

    // 第一次barrier：等待所有线程完成当前轮计算，此时所有线程都不会再修改当前轮的结果
    int barrier_ret = pthread_barrier_wait(thread_args->barrier);
    if (barrier_ret == PTHREAD_BARRIER_SERIAL_THREAD) {
        // 仅最后一个到达barrier的线程执行结果收集，此时没有线程会修改内存，无需担心竞态
        collectAllWork();
        // 标记收集完成，唤醒等待的线程
        pthread_mutex_lock(thread_args->mutex);
        thread_args->ready = 1;
        pthread_cond_broadcast(thread_args->cond);
        pthread_mutex_unlock(thread_args->mutex);
    }

    // 所有线程（包括执行收集的线程）统一等待收集完成
    pthread_mutex_lock(thread_args->mutex);
    while (thread_args->ready == 0) {
        pthread_cond_wait(thread_args->cond, thread_args->mutex);
    }
    pthread_mutex_unlock(thread_args->mutex);

    // 第二次barrier：等待所有线程都已读取到ready=1的状态，此时可以安全重置共享状态
    barrier_ret = pthread_barrier_wait(thread_args->barrier);
    if (barrier_ret == PTHREAD_BARRIER_SERIAL_THREAD) {
        // 最后一个到达的线程重置ready，此时没有线程会再读取本轮的ready值
        pthread_mutex_lock(thread_args->mutex);
        thread_args->ready = 0;
        pthread_mutex_unlock(thread_args->mutex);
    }

    // 到这里所有线程状态完全同步，可以安全进入下一轮计算
}

方案优势

• 完全符合必须使用barrier的要求，仅用同一个初始化好的barrier即可完成两轮同步
• 彻底解决ready状态的重置竞态问题：第二次barrier保证所有线程都已经读完ready=1，不会出现部分线程没读到就被重置的情况
• 兼容所有线程的调度时序：不管线程调度快慢，都不会出现永久等待或者提前执行下一轮的问题
• 不需要新增额外的同步原语，仅在原有逻辑上补充了状态同步的barrier即可

内容的提问来源于stack exchange，提问作者Pop Flamingo