开启后维持线程流的屏障（Java多线程）

在Java中，可以使用CyclicBarrier类来实现开启后维持线程流的屏障。

CyclicBarrier是一个同步辅助类，它允许一组线程相互等待，直到到达某个公共屏障点，然后继续执行。CyclicBarrier可以被重复使用，每次使用都会重置屏障。

下面是一个简单的示例代码：

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class BarrierExample {
    public static void main(String[] args) {
        int numberOfThreads = 3;
        CyclicBarrier barrier = new CyclicBarrier(numberOfThreads, () -> {
            System.out.println("所有线程到达屏障，继续执行");
        });

        for (int i = 0; i < numberOfThreads; i++) {
            Thread thread = new Thread(() -> {
                System.out.println("线程开始执行");
                try {
                    // 模拟线程执行一些任务
                    Thread.sleep(1000);
                    System.out.println("线程执行完毕，等待其他线程");
                    barrier.await(); // 等待其他线程到达屏障
                } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                }
                System.out.println("线程继续执行");
            });
            thread.start();
        }
    }
}

在以上代码中，首先创建了一个CyclicBarrier对象，并指定了需要等待的线程数量为3。然后使用for循环创建了3个线程，每个线程都执行一些任务，在任务完成后调用barrier.await()方法等待其他线程到达屏障。当所有线程都到达屏障时，执行屏障操作，即输出"所有线程到达屏障，继续执行"。然后所有线程继续执行。

注意：CyclicBarrier的构造函数中可以传入一个Runnable对象，该对象会在所有线程到达屏障时执行。这个Runnable对象可以用来执行一些屏障操作，比如汇总线程的执行结果。