Java并发工具：CountDownLatch和CyclicBarrier实例

原创我会带着你远行 2024-09-29 22:42 89阅读 0赞

在Java中，CountDownLatch和CyclicBarrier是两种常用的并发控制工具，用于协调多个线程的执行。

1. CountDownLatch：

CountDownLatch是一种倒计数型信号量。当它的初始值大于0时，等待该信号量的线程会被挂起，并阻塞到 CountDownLatch 的 count 减为 0。

实例：
```java
// 创建一个CountDownLatch，初始值为3
CountDownLatch latch = new CountDownLatch(3);

// 定义两个任务，每个任务都会尝试减少latch的count
new Thread(() -> {
    try {
        latch.countDown();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

new Thread(() -> {
    try {
        latch.countDown();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 最后，主线程会等待latch的count变为0
new Thread(() -> {
    try {
        latch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("All tasks finished.");
}).start();
```

2. CyclicBarrier：

CyclicBarrier是另一种线程同步工具，用于协调一组共享资源的线程。当一个线程到达 CyclicBarrier 时，它会被阻塞直到所有线程都通过该 barrier。

实例：
```java
// 创建一个CyclicBarrier，当barrier到达时会进行 barrier操作（例如打印当前线程ID）
CyclicBarrier barrier = new CyclicBarrier(2);

new Thread(() -> {
    try {
        // 线程1先到达barrier，会被阻塞直到其他线程也通过barrier
        barrier.await();
        System.out.println("Thread 1 reached barrier.");
    } catch (Exception e) {
        e.printStackTrace();
    }
}).start();

new Thread(() -> {
    try {
        // 线程2随后到达barrier，会被阻塞直到其他线程也通过barrier
        barrier.await();
        System.out.println("Thread 2 reached barrier.");
    } catch (Exception e) {
        e.printStackTrace();
    }
}).start();
```

以上就是CountDownLatch和CyclicBarrier这两种Java并发工具的实例。