如何设置Java Barrier的阈值

在Java中，可以使用CyclicBarrier类来设置Barrier的阈值。CyclicBarrier类有一个构造方法，可以指定需要等待的线程数量作为参数，这个数量就是Barrier的阈值。当等待的线程数量达到指定的阈值时，所有线程将被释放并继续执行。

下面是一个示例代码，演示如何设置CyclicBarrier的阈值：

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

public class BarrierExample {
    public static void main(String[] args) {
        int numberOfThreads = 3; // 设置Barrier的阈值为3

        CyclicBarrier barrier = new CyclicBarrier(numberOfThreads, new Runnable() {
            @Override
            public void run() {
                System.out.println("All threads have reached the barrier");
            }
        });

        for (int i = 0; i < numberOfThreads; i++) {
            Thread thread = new Thread(new Worker(barrier));
            thread.start();
        }
    }

    static class Worker implements Runnable {
        private CyclicBarrier barrier;

        public Worker(CyclicBarrier barrier) {
            this.barrier = barrier;
        }

        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " is waiting at the barrier");
                barrier.await(); // 等待所有线程到达Barrier
                System.out.println(Thread.currentThread().getName() + " has passed the barrier");
            } catch (InterruptedException | BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
    }
}

在上面的示例中，我们创建了一个CyclicBarrier对象，并指定了阈值为3。然后创建了3个Worker线程，每个线程在执行过程中都会调用CyclicBarrier的await()方法来等待其他线程。当所有线程都到达Barrier时，会执行指定的Runnable任务，并继续执行各个线程。