Java并发编程：CountDownLatch的简单应用实例

原创比眉伴天荒 2024-12-07 04:45 6阅读 0赞

`CountDownLatch`是Java并发工具包`java.util.concurrent`中的一个类，主要用于协调多个线程的操作。

下面是一个简单的使用`CountDownLatch`的例子：

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

public class CountDownLatchExample {
    // 创建一个计数器，初始值为N（你需要等待的线程数量）
    private final CountDownLatch countDownLatch = new CountDownLatch(3);

public void startThreads() {
        // 创建三个线程，每个线程都会调用countDown方法来减少计数器
        Thread t1 = new Thread(() -> countDownLatch.countDown()));
        Thread t2 = new Thread(() -> countDownLatch.countDown()));
        Thread t3 = new Thread(() -> countDownLatch.countDown()));

// 启动这三个线程
        t1.start();
        t2.start();
        t3.start();
    }

public void waitUntilAllThreadsFinish() throws InterruptedException {
        // 当计数器的值为0时，表示所有的线程都已经完成它们的任务了
        countDownLatch.await();
        System.out.println("所有线程已成功执行完毕。");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();
        example.startThreads();
        example.waitUntilAllThreadsFinish();
    }
}
```

在这个例子中，我们创建了一个计数器`countDownLatch`，初始值为3（表示需要等待的线程数量）。然后创建了三个线程，每个线程调用`countDown`方法来减少计数器。当计数器的值变为0时，主线程会调用`await()`方法，并在计数器变回非零值后执行回调。

这个例子展示了如何使用`CountDownLatch`来协调多个线程的操作。