云上数据，JUC有多强

后端

2023-09-23 03:04:09

CountDownLatch的概念与原理

CountDownLatch是一个同步工具类，它允许一个或多个线程等待其他线程完成各自任务。在Java中，CountDownLatch使用一个计数器来跟踪需要等待的线程数量，当计数器减少到0时，等待的线程被释放，可以继续执行。

CountDownLatch的使用场景

CountDownLatch主要用于以下场景：

多线程任务协调：当多个线程需要完成各自任务后，才能继续执行下一个步骤时，可以使用CountDownLatch来协调这些线程。
线程等待：当一个线程需要等待其他线程完成任务后，才能继续执行时，可以使用CountDownLatch来让该线程等待。
线程通信：当多个线程需要相互通信时，可以使用CountDownLatch来实现线程之间的通信，例如，一个线程完成任务后，可以使用CountDownLatch来通知其他线程继续执行。

CountDownLatch的优势

CountDownLatch具有以下优势：

使用简单：CountDownLatch的API非常简单，只需要几个方法即可实现线程同步或通信。
性能优异：CountDownLatch的实现非常高效，不会对程序的性能造成显著影响。
可靠性高：CountDownLatch是一个可靠的同步工具，不会出现死锁或其他问题。

CountDownLatch的示例代码

以下是一个使用CountDownLatch实现多线程任务协调的示例代码：

import java.util.concurrent.CountDownLatch;

public class CountDownLatchDemo {

    public static void main(String[] args) {
        // 创建一个CountDownLatch，计数器为3
        CountDownLatch latch = new CountDownLatch(3);

        // 创建三个线程，每个线程都将递减CountDownLatch的计数器
        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                System.out.println("线程" + Thread.currentThread().getName() + "正在执行");
                latch.countDown(); // 递减计数器
            }).start();
        }

        // 等待所有线程完成任务
        try {
            latch.await(); // 等待计数器减为0
            System.out.println("所有线程已完成任务");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}