Java并发工具库：CountDownLatch应用

原创我就是我 2024-11-07 14:36 33阅读 0赞

`CountDownLatch` 是 Java并发工具库中一个非常有用的同步辅助类，它允许一个或多个线程等待一组操作在其他线程中完成。`CountDownLatch`通过一个计数器来实现这一功能，该计数器的初始值由构造函数指定，每当一个任务完成时，计数器的值就会减少，当计数器的值达到零时，所有等待的线程都会被释放。

以下是 `CountDownLatch` 的一些基本应用场景和使用方法：

###应用场景1. **等待多个任务完成**：当需要等待多个任务完成后才能继续执行后续操作时，可以使用 `CountDownLatch`。
2. **初始化操作**：在应用程序启动时，可能需要完成一些初始化操作，这些操作可以并行执行，但必须在它们全部完成后才能继续。
3. **测试**：在多线程测试中，`CountDownLatch`可以用来确保测试环境正确设置。

### 使用方法1. **初始化**：创建一个 `CountDownLatch` 实例，并指定计数器的初始值，这个值通常等于需要等待的任务数量。

```javaCountDownLatch latch = new CountDownLatch(3);
 ```2. **计数器递减**：在每个任务完成时调用 `countDown()` 方法，以减少计数器的值。

```java new Thread(() -> {
//执行任务 latch.countDown();
 }).start();
 ```3. **等待计数器为零**：在需要等待所有任务完成的线程中调用 `await()` 方法，该方法会阻塞直到计数器的值为零。

```java try {
 latch.await();
//所有任务完成后的代码} catch (InterruptedException e) {
e.printStackTrace();
 }
 ```### 示例代码下面是一个使用 `CountDownLatch` 的简单示例，其中有三个线程并行执行任务，主线程等待这三个任务完成后继续执行。

```javaimport java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
 public static void main(String[] args) {
 final int threadCount =3;
CountDownLatch latch = new CountDownLatch(threadCount);

for (int i =0; i < threadCount; i++) {
 new Thread(() -> {
 try {
//模拟任务执行时间Thread.sleep(1000);
 System.out.println(Thread.currentThread().getName() + "完成");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
 latch.countDown();
 }
 }).start();
 }

try {
 latch.await();
 System.out.println("所有任务完成");
} catch (InterruptedException e) {
e.printStackTrace();
 }
 }
}
```在这个示例中，主线程创建了三个线程，每个线程在执行完毕后调用 `countDown()` 方法。主线程通过调用 `await()` 方法等待所有线程执行完毕。当所有线程都调用了 `countDown()` 方法，计数器的值变为零，`await()` 方法返回，主线程继续执行。