如何使用Java并发阶段器实现可重复循环使用的多线程栅栏-java教程-PHP中文网

cyclicbarrier 是 java 并发包中可重复使用的同步辅助类，用于让一组线程互相等待至全部到达栅栏后同时继续执行；支持屏障动作、超时与中断处理，适用于分阶段协同场景。

如何使用java并发阶段器实现可重复循环使用的多线程栅栏

Java 中没有直接叫“并发阶段器”的内置类，但你提到的“可重复循环使用的多线程栅栏”，实际指的是 CyclicBarrier —— 它正是为这种场景设计的：让一组线程互相等待，直到全部到达某个同步点（即“栅栏”），然后一起继续执行，并且可以重复使用。

什么是 CyclicBarrier？

CyclicBarrier 是 Java 并发包（java.util.concurrent）中的一个同步辅助类。它和 CountDownLatch 类似，但关键区别在于：可重置、可重复使用。每次所有参与线程调用 await() 后，栅栏就“打开”，线程继续执行；之后它自动重置，等待下一轮。

基本用法：创建与等待

使用步骤很简单：

构造时指定参与线程数（例如 3 个线程协作）
每个线程执行到同步点时调用 barrier.await()
当第 N 个线程调用 await()，所有线程同时被释放，继续向下执行

示例代码：

CyclicBarrier barrier = new CyclicBarrier(3);
<p>for (int i = 0; i  {
System.out.println(Thread.currentThread().getName() + " 开始工作");
// 模拟不同耗时任务
try { Thread.sleep((long)(Math.random() * 2000)); } catch (InterruptedException e) {}
System.out.println(Thread.currentThread().getName() + " 到达栅栏");
try {
barrier.await(); // 阻塞，直到其他线程也到达
} catch (Exception e) { e.printStackTrace(); }
System.out.println(Thread.currentThread().getName() + " 继续执行后续逻辑");
}).start();
}</p>

支持屏障动作（Barrier Action）

可在所有线程到达后、释放前，执行一个公共任务（比如汇总数据、记录日志）。通过构造函数传入 Runnable 实现：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

CyclicBarrier barrier = new CyclicBarrier(3, () -> {
    System.out.println("✅ 所有线程已就位，执行屏障动作（如：触发下一阶段）");
});

注意：该 Runnable 由**最后一个到达的线程执行**，不是额外线程。

处理中断与超时

生产环境建议避免永久阻塞。CyclicBarrier 支持带超时的 await(long timeout, TimeUnit unit)，超时未满足条件会抛出 TimeoutException；若线程被中断，则抛出 InterruptedException。此时栅栏进入 broken 状态，需调用 reset() 恢复（或新建实例）：