Java中CyclicBarrier线程同步使用方法

CyclicBarrier 是 Java 并发编程中一款强大且灵活的可重用同步工具，专为多线程协作场景而生——它让一组线程彼此等待，直至全部抵达公共屏障点后才集体继续执行，支持回调动作、超时控制与异常恢复机制，不仅能优雅应对并行计算、任务分片汇总、服务模块协同初始化等典型需求，还因其“可循环”特性远超 CountDownLatch 的一次性限制；掌握其核心用法与实战技巧，将助你轻松构建健壮、高效又易维护的并发程序。

在Java并发编程中，CyclicBarrier 是一种实用的线程同步工具，适用于多个线程必须相互等待到达某个公共屏障点后再继续执行的场景。它常用于多线程协作计算、并行任务拆分与汇总等操作。

什么是CyclicBarrier？

CyclicBarrier 字面意思是“可循环使用的屏障”。它允许一组线程互相等待，直到所有线程都到达一个共同的屏障点（barrier point），然后才一起继续执行。与 CountDownLatch 不同的是，CyclicBarrier 可以重复使用，一旦所有线程通过屏障，它会自动重置状态。

创建 CyclicBarrier 时需要指定参与等待的线程数量：

CyclicBarrier barrier = new CyclicBarrier(3);

表示当3个线程都调用 await() 方法后，屏障才会被解除。

基本使用方法

每个参与的线程在执行完自己的部分任务后，调用 barrier.await() 方法进行等待。该方法会阻塞线程，直到所有线程都调用了 await()。

示例代码：

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 {
                String name = Thread.currentThread().getName();
                System.out.println(name + " 正在准备...");
                Thread.sleep((long)(Math.random() * 3000)); // 模拟准备耗时
                System.out.println(name + " 准备完成，等待其他线程...");
                barrier.await(); // 等待其他线程
                System.out.println(name + " 继续执行后续任务。");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }).start();
    }
}
}

输出可能如下：

Thread-0 正在准备...
Thread-1 正在准备...
Thread-2 正在准备...
Thread-1 准备完成，等待其他线程...
Thread-0 准备完成，等待其他线程...
Thread-2 准备完成，等待其他线程...
所有线程已就位，开始下一步行动！
Thread-2 继续执行后续任务。
Thread-0 继续执行后续任务。
Thread-1 继续执行后续任务。

可以看到，所有线程都准备好后，定义在构造函数中的 回调任务 被触发，随后各线程继续向下执行。

关键特性与技巧

CyclicBarrier 提供了一些高级用法和注意事项，合理使用可以提升程序健壮性和灵活性。

• 支持屏障动作（Barrier Action）：可以在构造函数中传入一个 Runnable，它会在所有线程到达屏障后、被释放前执行。适合做统一的初始化或日志记录。
• 可重复使用：一旦所有线程通过屏障，CyclicBarrier 自动重置，可以再次使用。比如在一个循环中控制每轮并行任务的同步。
• 异常处理机制：如果某个线程在 await 时被中断或抛出异常，会导致整个屏障进入“破损”状态，其他线程也会收到 BrokenBarrierException。可通过 isBroken() 检查状态。
• 超时机制：可以使用 await(long timeout, TimeUnit unit) 设置最大等待时间，避免无限期阻塞。

带超时的示例：

try {
    barrier.await(5, TimeUnit.SECONDS);
} catch (TimeoutException e) {
    System.out.println("等待超时，部分线程未及时到达。");
}

适用场景建议

CyclicBarrier 特别适合以下情况：

• 多线程并行计算，需汇总结果前确保全部完成（如矩阵运算分块处理）
• 测试中模拟高并发请求同时发起
• 游戏开发中等待所有玩家加载完毕再开始下一阶段
• 服务启动阶段多个模块初始化完成后触发主流程

不适用于只需一次倒数的场景，此时应选择 CountDownLatch。

基本上就这些。CyclicBarrier 使用简单但功能强大，掌握好它能有效简化多线程协同逻辑。注意控制线程数量、处理异常，并合理设计屏障动作，就能写出稳定高效的并发程序。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Java中CyclicBarrier线程同步使用方法》文章吧，也可关注golang学习网公众号了解相关技术文章。