cyclicbarrier在Java中如何使用

CyclicBarrier是一個同步輔助類，它允許一組線程在達到某個屏障點之前彼此互相等待。在Java中，可以通過以下步驟來使用CyclicBarrier：

1. 創建CyclicBarrier對象并指定參與線程的數量和到達屏障點時需要執行的動作。

CyclicBarrier barrier = new CyclicBarrier(3, () -> {
    System.out.println("All threads have reached the barrier");
});

2. 創建并啟動線程，每個線程在到達屏障點之前調用CyclicBarrier的await()方法。

Thread t1 = new Thread(() -> {
    try {
        System.out.println("Thread 1 is waiting at the barrier");
        barrier.await();
        System.out.println("Thread 1 has passed the barrier");
    } catch (InterruptedException | BrokenBarrierException e) {
        e.printStackTrace();
    }
});
t1.start();

3. 當指定數量的線程都調用了await()方法后，CyclicBarrier會執行指定的動作，并重置屏障點，使得線程可以再次在屏障點等待。

Thread t2 = new Thread(() -> {
    try {
        System.out.println("Thread 2 is waiting at the barrier");
        barrier.await();
        System.out.println("Thread 2 has passed the barrier");
    } catch (InterruptedException | BrokenBarrierException e) {
        e.printStackTrace();
    }
});
t2.start();

通過以上步驟，可以實現多個線程在達到某個屏障點后進行同步操作。需要注意的是，CyclicBarrier只能被重置一次，之后需要重新創建新的CyclicBarrier對象。