Java 循环屏障 CyclicBarrier 怎么让一组线程到达同一点再继续-Java面试题-PHP中文网

cyclicbarrier是java并发包中支持重复使用的线程同步工具，用于让一组线程互相等待至全部到达屏障点后才共同继续执行；它可指定到达时由最后线程执行回调任务，且需处理interruptedexception和brokenbarrierexception异常。

java 循环屏障 cyclicbarrier 怎么让一组线程到达同一点再继续

CyclicBarrier 是 Java 并发包（java.util.concurrent）中用于协调多个线程在某个“屏障点”同步等待的工具。它的核心作用就是：**让一组线程互相等待，直到全部到达指定的同步点，才一起继续执行。** 这和 CountDownLatch 的“单次倒计时、不可重用”不同，CyclicBarrier 支持重复使用（即“循环”），适合多轮协作场景（比如多线程分段计算、并行迭代等）。

怎么创建并使用 CyclicBarrier

创建时需指定参与等待的线程总数，并可选传入一个 Runnable 任务——当所有线程都到达屏障点时，由**最后一个到达的线程**负责执行该任务（常用于汇总、日志、清理等）：

CyclicBarrier barrier = new CyclicBarrier(3, () -> {
    System.out.println("所有线程已就位，开始下一阶段");
});

每个线程在到达同步点时调用 barrier.await()：

如果还没凑够指定数量，当前线程会阻塞等待；
一旦达到指定数量，所有等待线程被同时唤醒，继续向下执行；
屏障被“释放”，可再次使用（下一轮等待）。

关键细节和注意事项

await() 方法会抛出两个受检异常，必须处理：

InterruptedException：线程在等待时被中断；
BrokenBarrierException：屏障已被破坏（如某线程超时、中断、或 await 失败后未重置）。

常见破坏屏障的情况包括：

deep-java-review

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

下载

某个线程在 await() 时被中断；
某个线程调用 await() 超时（使用带 timeout 的重载方法）且未等到其他线程；
屏障初始化后未重置，但之前已因异常进入破损状态。

可通过 isBroken() 检查当前屏障是否处于破损状态，用 reset() 强制重置（慎用，可能影响正在等待的线程）。

一个典型使用示例

模拟 3 个线程各自准备数据，全部就绪后再统一提交：

CyclicBarrier barrier = new CyclicBarrier(3, () -> {
    System.out.println("✅ 所有数据准备完毕，开始批量提交");
});
<p>for (int i = 0; i  {
System.out.println(Thread.currentThread().getName() + " 正在准备数据...");
try {
Thread.sleep(1000 + (long)(Math.random() * 2000)); // 模拟耗时差异
System.out.println(Thread.currentThread().getName() + " 数据准备完成");
barrier.await(); // 到达屏障点，等待其他线程
System.out.println(Thread.currentThread().getName() + " 开始提交...");
} catch (Exception e) {
e.printStackTrace();
}
}).start();
}</p>

输出效果类似：

Thread-0 正在准备数据...
Thread-1 正在准备数据...
Thread-2 正在准备数据...
Thread-1 数据准备完成
Thread-0 数据准备完成
Thread-2 数据准备完成
✅ 所有数据准备完毕，开始批量提交
Thread-0 开始提交...
Thread-1 开始提交...
Thread-2 开始提交...