java 栅栏（CyclicBarrier）

Java中的栅栏（CyclicBarrier）是一种用于协调多个线程并发工作的同步辅助类。与CountDownLatch不同，CyclicBarrier允许一组线程相互等待，直到所有线程都到达一个共同的屏障点（barrier）后，才继续执行。CyclicBarrier的主要特点是可以重复使用，因此适用于需要多个阶段的任务同步。
在这里插入图片描述
示例代码：

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;public class CyclicBarrierWithActionExample {public static void main(String[] args) {int threadCount = 3;CyclicBarrier barrier = new CyclicBarrier(threadCount, new BarrierAction());for (int i = 0; i < threadCount; i++) {new Thread(new TaskWithAction(barrier)).start();}}
}class BarrierAction implements Runnable {@Overridepublic void run() {System.out.println("所有线程都到达屏障点，执行barrierAction。");}
}class TaskWithAction implements Runnable {private final CyclicBarrier barrier;TaskWithAction(CyclicBarrier barrier) {this.barrier = barrier;}@Overridepublic void run() {try {System.out.println(Thread.currentThread().getName() + " 正在执行任务...");// 模拟任务执行Thread.sleep((long) (Math.random() * 1000));System.out.println(Thread.currentThread().getName() + " 到达屏障点。");barrier.await(); // 等待其他线程到达屏障点System.out.println(Thread.currentThread().getName() + " 继续执行。");} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}}
}

在这个例子中，当所有线程都到达屏障点时，会首先执行BarrierAction中的任务，然后再继续执行线程的后续代码。

一个模拟多阶段的任务，每个阶段所有线程都需要同步后才能进入下一个阶段。每个阶段完成后，还会执行一个额外的屏障操作。

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;public class MultiStageTaskExample {public static void main(String[] args) {int threadCount = 4;int stageCount = 3;CyclicBarrier barrier = new CyclicBarrier(threadCount, new BarrierAction());for (int i = 0; i < threadCount; i++) {new Thread(new Worker(barrier, stageCount)).start();}}
}class Worker implements Runnable {private final CyclicBarrier barrier;private final int stageCount;Worker(CyclicBarrier barrier, int stageCount) {this.barrier = barrier;this.stageCount = stageCount;}@Overridepublic void run() {try {for (int stage = 1; stage <= stageCount; stage++) {// 模拟每个阶段的任务System.out.println(Thread.currentThread().getName() + " 正在执行第 " + stage + " 阶段任务...");Thread.sleep((long) (Math.random() * 1000)); // 模拟任务执行时间// 等待其他线程到达屏障点System.out.println(Thread.currentThread().getName() + " 到达第 " + stage + " 阶段屏障点。");barrier.await();}} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}}
}class BarrierAction implements Runnable {@Overridepublic void run() {System.out.println("所有线程都已到达屏障点，准备进入下一阶段...");}
}