如何設置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任務，并繼續執行各個線程。