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

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！