Java并发工具：理解Semaphore和CountDownLatch的用法

原创小灰灰 2024-11-25 12:21 4阅读 0赞

在Java中，`Semaphore`和`CountDownLatch`是两种常用的并发控制工具。它们各自有不同的用途和用法。

1. Semaphore（信号量）：

- 作用：信号量是一种资源管理工具，用于限制同时访问特定资源的数量。例如，可以用来控制同一时间有多少个线程能操作共享内存区域。

- 基本使用：
```java
Semaphore semaphore = new Semaphore(3); // 初始化信号量为3

// 线程A尝试获取信号量
Thread threadA = new Thread(() -> {
    semaphore.acquire(); // 获取信号量
    System.out.println("Thread A: Execution completed");
    semaphore.release(); // 释放信号量
}));
threadA.start();
```

2. CountDownLatch（计数down latch）：

- 作用：CountDownLatch是一种多线程同步工具，用于在一个或多个线程执行完成后，通知一个或多个等待的线程。它的初始值为0，每次调用`countDown()`方法时减少1，当值为0时，其他线程会一直被阻塞，直到调用`countUp()`方法或者计数器自动重置。

- 基本使用：
```java
CountDownLatch countDownLatch = new CountDownLatch(3); // 初始化计数down latch为3

// 线程A尝试获取信号量并通知其他线程
Thread threadA = new Thread(() -> {
    countDownLatch.countDown(); // 减少1，当值为0时，会触发后续操作
    System.out.println("Thread A: Count down completed");
});
threadA.start();

// 等待所有计数器变为0后通知其他线程
new Thread(() -> {
    try {
        countDownLatch.await(5, TimeUnit.SECONDS)); // 等待直到计数器变为0，或者超时5秒
        System.out.println("All CountDown completed");
    } catch (InterruptedException | TimeoutException e) {
        e.printStackTrace();
    }
}).start();
```

总结起来，`Semaphore`用于控制对资源的访问，而`CountDownLatch`则是用于协调多个线程的执行。