当前位置：首页 > 文章列表 > 文章 > java教程 > CyclicBarrier用法详解与实战示例

CyclicBarrier用法详解与实战示例

2025-10-06 18:16:31 0浏览收藏

想要了解Java中`CyclicBarrier`的使用方法吗？本文将深入解析`CyclicBarrier`这一强大的同步工具，它允许一组线程在达到共同屏障点时互相等待，直到所有线程就绪后才继续执行，支持循环使用，非常适合多线程并行计算、游戏同步以及高并发测试等场景。与只能使用一次的`CountDownLatch`不同，`CyclicBarrier`具备可重用性。通过本文，你将学习如何创建`CyclicBarrier`，指定线程数量，以及可选的汇总任务。掌握`await()`方法的使用，了解线程中断或异常时可能抛出的`BrokenBarrierException`，并学会使用`reset()`方法重置屏障。通过实例代码，让你轻松掌握`CyclicBarrier`的实际应用，提升程序的并发协调能力。

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

在Java中如何使用CyclicBarrier线程屏障

在Java中，CyclicBarrier 是一个同步辅助类，用于让一组线程互相等待，直到所有线程都到达某个公共屏障点后再继续执行。它常用于多线程协作的场景，比如多个线程完成各自任务后，再一起进行下一步操作。

什么是CyclicBarrier？

CyclicBarrier 的“循环”特性意味着它可以在被所有线程释放后重用。与 CountDownLatch 不同，后者只能使用一次，而 CyclicBarrier 可以多次重复使用。

创建 CyclicBarrier 时需要指定参与的线程数量。当这些线程都调用了 await() 方法后，屏障就会被打破，所有等待的线程继续执行。你还可以在构造函数中传入一个 Runnable 任务，这个任务会在所有线程到达屏障点后、释放之前执行，通常用于做汇总或初始化操作。

基本使用方法

下面是一个简单的示例，展示如何使用 CyclicBarrier：

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();
    }
}
}

在这个例子中：