CountDownLatch 揭秘：让 Java 线程井然有序的幕后英雄！

2024-01-04 18:55:33

CountDownLatch的工作原理

CountDownLatch是一个计数器，它的初始值等于需要等待的线程数。当一个线程调用await()方法时，它将阻塞，直到计数器减为零。当所有等待的线程都调用了await()方法后，计数器将变为零，此时所有等待的线程都会被唤醒，继续执行。

CountDownLatch的使用场景

CountDownLatch常用于以下场景：

资源加载：当一个线程需要等待其他线程加载资源完成才能继续执行时，可以使用CountDownLatch来实现。
任务初始化：当一个线程需要等待其他线程完成初始化任务才能继续执行时，可以使用CountDownLatch来实现。
并行处理：当多个线程需要并行处理任务时，可以使用CountDownLatch来协调这些线程的执行顺序。

CountDownLatch的优势

CountDownLatch具有以下优点：

简洁高效：CountDownLatch的API非常简单，易于理解和使用。
可靠性强：CountDownLatch是Java并发编程中的一个基本工具，经过了多年的考验，非常可靠。
扩展性好：CountDownLatch可以很容易地扩展到多个线程的场景中。

CountDownLatch的示例代码

以下是一个使用CountDownLatch来实现资源加载的示例代码：

public class CountDownLatchExample {

    private static final int NUM_THREADS = 10;

    public static void main(String[] args) throws InterruptedException {
        // 创建一个CountDownLatch，初始值为10
        CountDownLatch latch = new CountDownLatch(NUM_THREADS);

        // 创建10个线程，每个线程都将调用countDown()方法来减少计数器
        for (int i = 0; i < NUM_THREADS; i++) {
            new Thread(() -> {
                // 加载资源
                System.out.println("Loading resources...");

                // 调用countDown()方法来减少计数器
                latch.countDown();
            }).start();
        }

        // 等待所有线程都完成加载资源
        latch.await();

        // 所有线程都完成加载资源后，继续执行
        System.out.println("All resources loaded!");
    }
}