Java并发工具类理解：CountDownLatch和Semaphore示例

原创ゞ浴缸里的玫瑰 2024-09-12 21:30 63阅读 0赞

`CountDownLatch` 和 `Semaphore` 都是 Java 中的并发工具类，用于管理多个线程之间的交互。下面我会分别给出这两个工具类的简单示例。

1. CountDownLatch

CountDownLatch 是一个只允许一个信号被解除或到达零值的计数器。当它的初始值为 n（n>0）时，每个等待这个 CountDownLatch 的线程都必须在调用 `countDown()` 方法之前设置好其计数值为 n（n>0）。

示例：
```java
import java.util.concurrent.CountDownLatch;

public class CounterExample {
    public static void main(String[] args) {
        // 初始化一个CountDownLatch，初始值为3
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建三个线程，每个线程调用countDown方法减1
        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                // 模拟耗时操作
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

// 减少计数器的值
                countDownLatch.countDown();

}).start();
        }

// 等待所有计数器被消耗完
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("All countdowns completed!");
    }
}
```
在这个示例中，我们创建了一个 `CountDownLatch`，初始值为 3。然后创建了三个线程，每个线程调用 `countDown()` 函数减1。

当所有计数器都被消耗完时（也就是 `countDownLatch.await()`），主线程会打印出 "All countdowns completed!" 这个信息。