Java 中并发编程怎么使用 CyclicBarrier 实现多线程阶段性同步-Java面试题-PHP中文网

cyclicbarrier 是 java 并发包中用于多线程阶段性同步的可重用工具，支持指定线程数、屏障动作、超时等待及异常处理，适用于固定规模的分阶段协作场景。

java 中并发编程怎么使用 cyclicbarrier 实现多线程阶段性同步

CyclicBarrier 是 Java 并发包（java.util.concurrent）中用于多线程**阶段性同步**的核心工具之一。它让一组线程在到达某个“屏障点”时相互等待，直到全部线程都到达后才一起继续执行——非常适合分阶段协作的场景，比如并行计算的多个子任务完成后统一汇总、模拟多角色协同启动等。

理解 CyclicBarrier 的核心行为

与 CountDownLatch 不同，CyclicBarrier 是可重用的（cyclic），且关注的是“所有线程同时抵达后放行”，而非“等待一个事件完成”。它的关键特性包括：

构造时指定参与线程数（parties），即需要多少个线程调用 await() 才能触发释放
任意线程调用 await() 后会被阻塞，直到其他线程也陆续调用 await() 补齐人数
当最后一个线程调用 await() 时，所有线程被同时唤醒，继续向下执行
可选传入一个 Runnable 作为“屏障动作”（barrier action），由最后一个到达的线程在释放前执行（常用于汇总、日志、状态检查等）
支持超时等待（await(long timeout, TimeUnit unit)），避免因某线程异常导致全体卡死

典型使用步骤：三步构建阶段性同步

以“4 个工人并行加工零件，每轮加工完需共同质检后再进入下一轮”为例：

deep-java-review

Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...

下载

1. 创建 CyclicBarrier 实例：
CyclicBarrier barrier = new CyclicBarrier(4, () -> System.out.println("✅ 全部完成，开始质检..."));
这里 4 表示需 4 个线程到达，lambda 是质检逻辑（仅由最后到的线程执行一次）
2. 每个线程在阶段末尾调用 await()：
在各自加工逻辑后插入 barrier.await();。若任一线程中断或超时，屏障会破溃（broken），后续调用将抛 BrokenBarrierException
3. 处理异常与重用：
在 await() 外包裹 try-catch，捕获 InterruptedException、BrokenBarrierException 和 TimeoutException；
若未破溃，屏障可重复使用（如进入下一轮加工），无需重建

实战代码片段（带错误处理与重用）

以下是一个可运行的简化示例：

CyclicBarrier barrier = new CyclicBarrier(3, () -> {
    System.out.println("? 阶段一结束，汇总数据...");
});
<p>for (int i = 0; i  {
try {
System.out.println(Thread.currentThread().getName() + " 开始阶段一任务");
Thread.sleep(500 + (long)(Math.random() * 500)); // 模拟不同耗时
System.out.println(Thread.currentThread().getName() + " 完成阶段一");</p><pre class="brush:php;toolbar:false;">        barrier.await(); // 等待其他线程

        System.out.println(Thread.currentThread().getName() + " 进入阶段二");
        Thread.sleep(300);

    } catch (InterruptedException | BrokenBarrierException e) {
        System.err.println(Thread.currentThread().getName() + " 被中断或屏障异常: " + e.getMessage());
    }
}, "Worker-" + i).start();

}

输出中你会看到：3 个 Worker 完成时间不同，但都停在 await() 处；等最后一个到达，屏障动作执行，然后 3 个线程才几乎同时打印“进入阶段二”——这就是阶段性同步的效果。

注意事项与避坑提示

屏障破溃（broken）后不可恢复：一旦发生中断、超时或屏障动作抛异常，isBroken() 返回 true，后续 await() 会立即抛 BrokenBarrierException；需调用 reset() 重置（但会唤醒所有等待线程并抛异常），或新建实例
屏障动作不要耗时或阻塞：它由最后一个到达线程串行执行，若太慢会拖慢全体进度
慎用共享变量做屏障条件：CyclicBarrier 本身不保证内存可见性，若需依赖其他线程写入的状态，应在 await() 前加 volatile 或显式同步
和 Phaser 对比：若需动态增减参与者、分层屏障或更细粒度控制，建议改用 Phaser；CyclicBarrier 更适合固定规模、结构清晰的阶段同步

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南