Java并发编程：CountDownLatch和CyclicBarrier示例

原创超、凢脫俗 2024-09-20 00:12 48阅读 0赞

`CountDownLatch` 和 `CyclicBarrier` 是 Java 中两个常用的并发工具，它们主要用于协调多个线程的执行顺序。

1. CountDownLatch：
   - 它有一个初始计数值。
   - 当一个或多个等待它的线程被唤醒时，该计数减一。
   - 当计数为0时，阻塞所有在CountDownLatch上设置相同期望值的线程。

2. CyclicBarrier：
   - 它是一个同步屏障，允许多个线程同时到达这里。
   - 当一个线程成功到达屏障后，它会调用`barrier.await(long timeout, TimeUnit unit)}`方法等待其他线程到达这里。
   - 当所有线程都成功到达屏障时，所有被阻塞的线程都会被唤醒。

示例代码：

```java
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;

public class ConcurrencyDemo {
    public static void main(String[] args) {
        // 使用CountDownLatch
        CountDownLatch countDownLatch = new CountDownLatch(3);
        new Thread(() -> countDownLatch.countDown(), "Thread1").start();
        new Thread(() -> countDownLatch.countDown(), "Thread2").start();
        try {
            if (!countDownLatch.await(5, TimeUnit.SECONDS))) {
                System.out.println("All threads did not reach barrier in 5 seconds.");
                return;
            }
            System.out.println("All threads successfully reached the barrier after waiting.");
        } catch (InterruptedException e) {
            System.out.println("Interrupted while awaiting barrier: " + e.getMessage());
        }

// 使用CyclicBarrier
        CyclicBarrier cyclicBarrier = new CyclicBarrier(2);
        new Thread(() -> cyclicBarrier.await(), "Thread3").start();
        new Thread(() -> cyclicBarrier.await(), "Thread4").start();
        try {
            if (!cyclicBarrier.await(5, TimeUnit.SECONDS)))) {
                System.out.println("All threads did not reach barrier in 5 seconds.");
                return;
            }
            System.out.println("All threads successfully reached the barrier after waiting.");
        } catch (InterruptedException e) {
            System.out.println("Interrupted while awaiting barrier: " + e.getMessage());
        }

}
}
```

这个示例中，`CountDownLatch` 和 `CyclicBarrier` 分别用于协调线程的执行。