C++ Barrier创建方法及多线程迭代阻塞问题求助

嘿，我之前也踩过一模一样的坑！你这个情况十有八九是从Stack Overflow抄的那个自定义barrier类没做复用重置逻辑——毕竟boost::barrier本身是支持一轮接一轮重复同步的，但很多简易手写实现只考虑了单次等待的场景，第一轮用完后内部状态就乱了，第二轮自然就挂住了。

最常见的问题：Barrier没有重置状态 #

很多简易barrier实现的逻辑是：初始化时设好线程数，每来一个线程计数器减1，减到0就唤醒所有等待线程，但计数器不会变回初始值，也没有标记“这是第几轮同步”。这样第二轮线程再调用wait()时，计数器已经是0了，逻辑直接乱套，线程要么直接跳过等待，要么永远阻塞。

给你一个支持复用的Barrier实现（对标boost::barrier） #

这个版本用了「代次（generation）」的概念，每一轮同步对应一个新的代次，所有线程完成一轮后自动重置计数器，完美支持多轮迭代：

#include <mutex>
#include <condition_variable>

class barrier {
public:
    explicit barrier(std::size_t thread_num) 
        : total_threads(thread_num), remaining_threads(thread_num), generation(0) {}

    void wait() {
        std::unique_lock<std::mutex> lock(mutex_);
        const auto current_gen = generation;

        // 当前线程到达，计数器减1
        if (--remaining_threads == 0) {
            // 所有线程都到了，重置计数器，更新代次，唤醒所有人
            generation++;
            remaining_threads = total_threads;
            cond_var.notify_all();
        } else {
            // 等待直到当前代次结束（也就是所有线程都完成这一轮）
            cond_var.wait(lock, [this, current_gen] {
                return generation != current_gen;
            });
        }
    }

private:
    std::mutex mutex_;
    std::condition_variable cond_var;
    const std::size_t total_threads;
    std::size_t remaining_threads;
    std::size_t generation;
};

再检查你的顶层线程逻辑 #

除了barrier本身的问题，还要确认这几点：

• 每个线程在每一轮迭代结束后都调用了barrier.wait()，没有任何线程遗漏（比如某条分支没执行wait，那其他线程会永远等它）
• 线程在第一轮执行后有没有异常退出（比如抛出未捕获的异常直接终止），导致剩下的线程凑不够4个，一直卡在等待
• 确保所有线程共享同一个barrier实例，别每个线程都自己创建一个（这种低级错误也很常见）

调试小技巧 #

要是换了上面的barrier还是有问题，你可以在wait()里加几句日志，比如打印线程ID、当前剩余线程数、当前代次，看看第二轮时这些值是不是正常变化——一眼就能看出哪里出问题。

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