当前位置：首页 > 文章列表 > 文章 > java教程 > CyclicBarrier线程同步方法详解

CyclicBarrier线程同步方法详解

2026-02-18 14:25:36 0浏览收藏

CyclicBarrier 是 Java 中强大而灵活的线程同步工具，专为多线程在指定屏障点协同等待、集体释放而设计——当预设数量的线程全部调用 await() 后，它们会同时被唤醒继续执行，且该屏障可循环复用，支持自定义屏障动作、超时控制与异常恢复（如 reset() 重置），广泛应用于并行计算分阶段处理、并发性能压测及系统模块化启动等真实场景；掌握它，让你的多线程协作从“各自为战”跃升为“步调一致”的高效协同。

如何在Java中使用CyclicBarrier协调多个线程

在Java中，CyclicBarrier 是一个同步工具，用于让一组线程在执行到某个共同的屏障点时相互等待，直到所有线程都到达该点后，再一起继续执行。它特别适用于多线程协作完成阶段性任务的场景，比如并行计算中的分阶段处理。

什么是CyclicBarrier？

CyclicBarrier 允许指定数量的线程在执行过程中互相等待，当所有线程都调用了 await() 方法后，这些线程才会同时被释放，继续执行后续操作。这个“屏障”可以被重复使用，因此称为“循环的”（cyclic）。

构造方法如下：

CyclicBarrier(int parties)
CyclicBarrier(int parties, Runnable barrierAction)

其中，parties 表示需要等待的线程数量；第二个构造函数还可以传入一个 Runnable 任务，该任务会在所有线程都到达屏障点后、被释放前执行一次。

基本使用示例

以下是一个简单的例子，展示4个线程协同工作，每个线程执行一部分任务，然后在屏障处等待，全部到达后再继续：

import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    public static void main(String[] args) {
        int threadCount = 4;
        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();
        }
    } }

输出可能类似：

Thread-0 正在执行第一阶段任务...
Thread-2 正在执行第一阶段任务...
Thread-1 正在执行第一阶段任务...
Thread-3 正在执行第一阶段任务...
Thread-2 到达屏障点，等待其他线程...
Thread-0 到达屏障点，等待其他线程...
Thread-1 到达屏障点，等待其他线程...
Thread-3 到达屏障点，等待其他线程...
✅ 所有线程已就位，开始下一阶段！
Thread-3 继续执行第二阶段任务...
Thread-1 继续执行第二阶段任务...
Thread-0 继续执行第二阶段任务...
Thread-2 继续执行第二阶段任务...

常见应用场景

CyclicBarrier 在实际开发中有多种用途：

并行计算分阶段同步：多个线程分别处理数据块，在每阶段结束时同步，确保所有部分都完成后再进入下一阶段。
性能测试：让多个线程同时开始执行任务，以测试并发性能。
游戏或模拟系统启动：所有玩家或模块准备就绪后，统一进入游戏状态。

注意事项与异常处理

使用 CyclicBarrier 时需要注意：

如果某个线程在等待期间被中断，会抛出 InterruptedException，其他正在等待的线程会收到 BrokenBarrierException，表示屏障已被破坏。
避免长时间阻塞在 await() 中，必要时可使用带超时的版本：await(long timeout, TimeUnit unit)。
一旦屏障被打破（例如某个线程中断），需要重新创建 CyclicBarrier 实例或调用 reset() 方法重置（注意 reset() 会影响正在等待的线程）。

基本上就这些。CyclicBarrier 使用简单，适合需要阶段性同步的多线程协作场景，合理使用能有效提升程序的协调性和可读性。

本篇关于《CyclicBarrier线程同步方法详解》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！