CyclicBarrier是一个可重用的同步工具,用于让多个线程在到达共同屏障点时相互等待,直至所有线程就绪后再继续执行。它支持循环使用,与仅能使用一次的CountDownLatch不同,适用于多线程并行计算、游戏同步或高并发测试等场景。创建时需指定线程数量和可选的汇总任务,当所有线程调用await()后,汇总任务执行,随后释放所有线程。若某线程中断或异常,其他线程将抛出BrokenBarrierException,还可通过reset()方法重置屏障以供重复使用。

在Java中,CyclicBarrier 是一个同步辅助类,用于让一组线程互相等待,直到所有线程都到达某个公共屏障点后再继续执行。它常用于多线程协作的场景,比如多个线程完成各自任务后,再一起进行下一步操作。
什么是CyclicBarrier?
CyclicBarrier 的“循环”特性意味着它可以在被所有线程释放后重用。与 CountDownLatch 不同,后者只能使用一次,而 CyclicBarrier 可以多次重复使用。
创建 CyclicBarrier 时需要指定参与的线程数量。当这些线程都调用了 await() 方法后,屏障就会被打破,所有等待的线程继续执行。你还可以在构造函数中传入一个 Runnable 任务,这个任务会在所有线程到达屏障点后、释放之前执行,通常用于做汇总或初始化操作。
基本使用方法
下面是一个简单的示例,展示如何使用 CyclicBarrier:
立即学习“Java免费学习笔记(深入)”;
Android文档-开发者指南-第一部分:入门-中英文对照版 Android提供了丰富的应用程序框架,它允许您在Java语言环境中构建移动设备的创新应用程序和游戏。在左侧导航中列出的文档提供了有关如何使用Android的各种API来构建应用程序的详细信息。第一部分:Introduction(入门) 0、Introduction to Android(引进到Android) 1、Application Fundamentals(应用程序基础) 2、Device Compatibility(设备兼容性) 3、
import java.util.concurrent.CyclicBarrier;public class CyclicBarrierExample { public static void main(String[] args) { int threadCount = 3; CyclicBarrier barrier = new CyclicBarrier(threadCount, () -> { System.out.println("所有线程已到达屏障点,开始汇总处理..."); });
for (int i = 1; i <= threadCount; i++) { new Thread(() -> { try { System.out.println(Thread.currentThread().getName() + " 正在执行任务"); Thread.sleep((long)(Math.random() * 2000)); // 模拟耗时操作 System.out.println(Thread.currentThread().getName() + " 到达屏障点,等待其他线程"); barrier.await(); // 等待其他线程 System.out.println(Thread.currentThread().getName() + " 继续执行后续任务"); } catch (Exception e) { e.printStackTrace(); } }).start(); } }}
在这个例子中:
- 我们创建了一个需要3个线程参与的 CyclicBarrier。
- 每个线程执行自己的任务后调用 barrier.await(),进入等待状态。
- 当第3个线程调用 await 后,预设的 Runnable 任务被执行(打印汇总信息),然后所有线程被释放,继续执行后续代码。
实际应用场景
CyclicBarrier 特别适合以下几种情况:
- 多线程并行计算:比如将一个大数组分成几段,由不同线程处理,全部完成后统一合并结果。
- 游戏启动同步:多个玩家线程准备就绪后,才开始游戏回合。
- 测试并发行为:在性能测试中,让多个线程同时发起请求,模拟高并发场景。
注意事项
使用 CyclicBarrier 时需要注意:
- 如果某个线程在等待过程中被中断或抛出异常,其他线程会收到 BrokenBarrierException,表示屏障已被破坏。
- 避免在 await() 中执行耗时过长的操作,否则会拖慢整体进度。
- 可以调用 reset() 方法重置屏障,使它可以被再次使用,但要确保没有线程正在等待。
基本上就这些。CyclicBarrier 使用简单,但在控制线程协同方面非常有效。合理使用能提升程序的并发协调能力。









