在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任務,并繼續執行各個線程。