阅读量:0
在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任务，并继续执行各个线程。
