如何设置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任务，并继续执行各个线程。