Java计时器 CountDownLatch，轻松实现线程同步！

2023-02-11 07:38:57

CountDownLatch：掌握 Java 中的线程同步和任务依赖

线程同步：并发编程的基石

在 Java 并发编程中，线程同步是至关重要的。它确保了多个线程可以同时执行任务，并在它们都完成任务后继续执行后续操作。为此，Java 提供了多种内置的同步机制，而 CountDownLatch 就是其中之一。

CountDownLatch：理解其原理

CountDownLatch 是一个基于 AQS（AbstractQueuedSynchronizer）实现的计时器。它的工作原理很简单：它维护着一个计数器，当多个线程同时调用 CountDownLatch.await() 方法时，它们都会被阻塞，直到计数器减为 0。

CountDownLatch 的应用场景

CountDownLatch 拥有广泛的应用场景，包括：

线程同步： 确保多个线程同时执行任务，并在它们都完成任务后继续执行后续操作。
任务依赖： 实现任务依赖，即当一个任务完成后，另一个任务才能开始执行。
资源控制： 控制对共享资源的访问，防止多个线程同时访问同一资源。

使用 CountDownLatch：逐步示例

使用 CountDownLatch 非常简单。首先，创建一个 CountDownLatch 对象，并指定计数器的初始值。然后，多个线程可以同时调用 CountDownLatch.countDown() 方法来减少计数器的值。当计数器减为 0 时，所有调用 CountDownLatch.await() 方法的线程都会被唤醒，继续执行后续操作。

以下是一个 CountDownLatch 的使用示例：

import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {

    public static void main(String[] args) {
        // 创建一个 CountDownLatch 对象，并指定计数器的初始值为 5
        CountDownLatch latch = new CountDownLatch(5);

        // 创建 5 个线程，每个线程都调用 CountDownLatch.countDown() 方法来减少计数器的值
        for (int i = 0; i < 5; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + " is running...");
                latch.countDown();
            }).start();
        }

        // 主线程调用 CountDownLatch.await() 方法，等待计数器减为 0
        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 所有线程都完成任务后，主线程继续执行后续操作
        System.out.println("All threads have finished their tasks!");
    }
}