std::barrier用于多线程在指定点集体等待并统一放行,适用于分阶段并行任务;需构造时指定线程数,调用arrive_and_wait()完成一轮同步,支持重复使用,但要求每线程必调用且不可动态重置。

std::barrier 的基本用法和典型适用场景
std::barrier 是 C++20 引入的同步原语,专为「多个线程在某一点集体等待、全部到达后统一放行」这种模式设计。它比 std::condition_variable + 手动计数更轻量,也比 std::latch 更适合重复使用的分阶段任务(比如迭代式计算、流水线处理)。
常见误用是把它当 std::mutex 用——它不保护数据,只协调到达时机;也不支持单次等待(那是 std::latch 的事)。
- 必须在构造时指定参与线程数(
std::barrier构造函数参数),且该数量不能动态变更 - 每个线程调用
arrive_and_wait()阻塞直到所有线程都到达;若只需通知不等待,可用arrive()(但需自行处理后续同步) - 同一
std::barrier实例可被多次重复使用,每次都是完整的一轮同步
分阶段计算中 barrier 的典型结构
假设你有 4 个线程并行处理一批数据,每轮分三阶段:读取 → 计算 → 写出。各阶段之间必须严格串行(即所有线程完成阶段1后,才能开始阶段2),这时 std::barrier 就是自然选择。
关键点在于:每个阶段末尾调用一次 arrive_and_wait(),而不是在阶段入口加锁或轮询。
- 不要在循环外初始化 barrier——如果阶段数固定,构造一次即可;若阶段数动态变化,需重新构造新实例(旧实例不可重置)
- 避免在 barrier 等待期间持有锁,否则可能造成死锁或性能瓶颈
- 若某线程提前退出(如异常或 early-return),未调用
arrive_and_wait(),其余线程将永久阻塞——务必确保每个路径都调用
示例片段:
std::barrier sync_point{num_threads};
for (int round = 0; round
<h3>与 std::latch 和 std::semaphore 的关键区别</h3>
<p>容易混淆的是:为什么不用 <code>std::latch</code>?因为 <code>std::latch</code> 是一次性计数器,用完即废;而分阶段任务需要多轮复用,<code>std::barrier</code> 的 <code>arrive_and_wait()</code> 每次都会重置内部计数,天然适配循环场景。</p>
<p><code>std::semaphore</code> 虽然也能模拟,但需手动管理信号量值,易出错(比如多减、少增),且语义不清晰——它表达的是资源许可,不是“所有人到齐才继续”。</p>
-
std::barrier的arrive_and_wait()是原子操作:抵达 + 等待 + 自动重置计数,无竞态风险 -
std::latch的wait()不消耗计数,arrive()才减,无法自动重置,不适合多轮 - 所有标准同步原语都不提供超时机制(C++20 标准版),如有超时需求,得自己包装或用第三方库
实际编码中容易忽略的细节
最常踩的坑是线程数和 barrier 构造参数不一致。比如启动了 8 个线程,却传入 std::barrier{4},结果一半线程永远等不到另一半——程序卡死,且无编译错误或运行时提示。
- 务必确保传给
std::barrier构造函数的数值等于实际参与同步的线程数(不是硬件线程数,也不是线程池大小) - 如果使用线程池(如
std::jthread或自定义池),注意:每个工作线程调用arrive_and_wait()才算一个“参与者”,空闲线程不计入 -
std::barrier的析构行为是未定义的(UB),如果还有线程在等待,就销毁它——务必保证所有线程已退出或已脱离 barrier 同步流 - MSVC 19.30+、GCC 11+、Clang 12+ 才完整支持;老编译器会报错或静默降级,建议加
#if __cpp_lib_barrier宏检查
复杂点从来不在语法,而在谁该等、等几次、谁先退——这些必须靠任务逻辑本身约束,barrier 只忠实地执行“数够了就放行”。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











