登录
首页 >  文章 >  java教程

Java多线程:如何优雅地等待两个子线程执行完毕再继续主线程?

时间:2025-03-06 10:19:24 128浏览 收藏

Java多线程编程中,主线程常常需要等待多个子线程执行完毕才能继续执行。本文介绍两种高效优雅的解决方案:`CompletableFuture.allOf` 和 `CountDownLatch`。`CompletableFuture.allOf` 适合基于异步操作的场景,通过组合多个`CompletableFuture`,只有所有子线程任务完成后才会执行后续操作。`CountDownLatch` 则适用于需要精确控制线程同步的场景,主线程通过`await()`方法等待计数器归零,子线程执行完毕后调用`countDown()`方法递减计数器。两种方法都可有效解决主线程等待子线程完成的问题,确保程序的正确性和稳定性,并对线程安全和共享变量访问进行了讨论,帮助开发者选择最合适的方案。

Java多线程:如何优雅地等待两个子线程执行完毕再继续主线程?

Java主线程如何等待两个子线程执行完毕?

在多线程编程中,主线程常常需要等待多个子线程完成任务后才能继续执行后续操作。本文介绍两种常用的方法:CompletableFuture.allOfCountDownLatch,来优雅地解决这个问题。

方法一:使用 CompletableFuture.allOf

CompletableFuture.allOf 方法接收多个 CompletableFuture 对象作为参数,并返回一个新的 CompletableFuture。只有当所有输入的 CompletableFuture 都完成时,这个新的 CompletableFuture 才会完成。

示例代码:

CountDownLatch latch = new CountDownLatch(2); // 初始化计数器为 2 (两个子线程)

Thread threadA = new Thread(() -> {
    // 子线程 A 的任务
    latch.countDown(); // 计数器减 1
});

Thread threadB = new Thread(() -> {
    // 子线程 B 的任务
    latch.countDown(); // 计数器减 1
});

threadA.start();
threadB.start();

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

// 所有子线程都执行完毕后执行此代码
// 处理共享数据

线程安全与共享变量

如果主线程和子线程需要共享数据(例如 ArrayList),必须确保数据访问的线程安全。ArrayList 不是线程安全的,建议使用线程安全的替代方案,例如 ConcurrentHashMapCopyOnWriteArrayList

选择哪种方法取决于具体场景。CompletableFuture 更适用于基于异步操作的场景,而 CountDownLatch 更适用于需要精确控制线程同步的场景。 两种方法都能有效地解决主线程等待子线程完成的问题,确保程序的正确性和稳定性。

到这里,我们也就讲完了《Java多线程:如何优雅地等待两个子线程执行完毕再继续主线程?》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于的知识点!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>