Java多线程通信：CountDownLatch深入解析与实战应用

Android

2023-03-23 06:08:06

CountDownLatch：多线程中的同步神器

简介

在多线程编程中，协调线程之间的同步是一项重要的任务。CountDownLatch 是一种用于等待特定数量的线程完成任务的同步工具。它提供了一种简单高效的方式来控制线程之间的执行顺序。

工作原理

CountDownLatch 内部维护一个计数器，初始值为一个正整数。当其他线程调用 countDown() 方法时，计数器会递减 1。当计数器变为 0 时，所有正在等待的线程将被唤醒，继续执行后续任务。

使用场景

CountDownLatch 在多线程编程中有很多应用场景，例如：

等待所有线程完成初始化后再开始执行后续任务
等待所有线程完成某个任务后再汇总结果
控制线程之间的同步，确保在特定条件下才执行某些操作

代码示例

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

import java.util.concurrent.CountDownLatch;

public class CountDownLatchDemo {

    public static void main(String[] args) {
        // 创建一个初始值为 3 的 CountDownLatch
        CountDownLatch latch = new CountDownLatch(3);

        // 创建 3 个线程
        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                // 模拟执行耗时的任务
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                // 任务完成后递减计数器
                latch.countDown();
            }).start();
        }

        // 主线程等待所有线程完成
        try {
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 所有线程完成，继续执行后续任务
        System.out.println("所有线程执行完成");
    }
}