在Java中如何使用CyclicBarrier实现线程屏障_CyclicBarrier类应用指南-java教程-PHP中文网

在Java中如何使用CyclicBarrier实现线程屏障_CyclicBarrier类应用指南

P粉602998670

发布： 2025-11-19 14:42:38

原创

139人浏览过

CyclicBarrier是一种可重复使用的同步屏障，允许多个线程互相等待到达共同屏障点后继续执行。它通过await()方法阻塞线程，直到所有线程就绪，再统一释放，并可执行回调任务。支持固定数量线程协作、可选Runnable操作及异常处理，适用于分阶段并行计算等场景。与CountDownLatch不同，后者为一次性使用且是主线程等待其他线程完成。

在java中如何使用cyclicbarrier实现线程屏障_cyclicbarrier类应用指南

在Java并发编程中，CyclicBarrier是一种同步工具，用于让一组线程在执行到某个点时相互等待，直到所有线程都到达该点后再继续执行。这种机制非常适合多线程协作的场景，比如并行计算中的阶段性同步。

理解CyclicBarrier的基本原理

CyclicBarrier的字面意思是“可循环使用的屏障”。它允许指定数量的线程在执行过程中到达一个公共的屏障点（barrier point），然后一起被释放。这个过程可以重复使用，因此称为“循环”。

当调用await()方法时，线程会被阻塞，直到所有参与的线程都调用了await()。一旦最后一个线程到达，所有等待的线程将同时被唤醒，并可选择性地执行一个预定义的“回调任务”。

关键特性：

支持固定数量的参与线程
可重复使用（重置后可再次使用）
可选的屏障操作（Runnable任务）

创建和使用CyclicBarrier实例

构造CyclicBarrier时需要传入参与线程的数量，也可以指定一个在所有线程到达后执行的Runnable任务。

立即学习“Java免费学习笔记（深入）”；

示例代码如下：

码哩写作

最懂作者的AI辅助创作工具

查看详情

CyclicBarrier barrier = new CyclicBarrier(3, () -> {
    System.out.println("所有线程已就绪，开始下一阶段");
});
<p>for (int i = 0; i < 3; 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();
}

登录后复制

在这个例子中，三个线程各自准备完成后调用await()，只有当第三个线程调用后，屏障才会被打破，所有线程继续执行。