Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $YECBGYFECGEAFWHA as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2

Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $BBWFDDBHHYHDXXAB as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2
在Java中如何使用CountDownLatch实现线程同步_创想鸟

在Java中如何使用CountDownLatch实现线程同步

CountDownLatch通过计数器实现线程同步,初始化指定计数值,每调用一次countDown()计数减一,当计数为零时await()方法返回,等待线程继续执行。

在java中如何使用countdownlatch实现线程同步

在Java中,CountDownLatch 是一种非常实用的线程同步工具类,位于 java.util.concurrent 包下。它允许一个或多个线程等待其他线程完成操作后再继续执行。其核心机制是基于一个计数器,当计数器归零时,所有被阻塞的线程会被释放。

基本原理

CountDownLatch 初始化时指定一个正整数作为计数器值。每当一个线程完成任务后调用 countDown() 方法,计数器减一。其他线程通过调用 await() 方法阻塞自己,直到计数器变为0。一旦计数器归零,所有等待中的线程自动恢复执行。

需要注意的是,CountDownLatch 的计数器只能使用一次,一旦归零就无法重置。

常见使用场景

适合用于以下情况:

立即学习“Java免费学习笔记(深入)”;

主线程等待多个工作线程初始化完成后再启动 多个线程并发执行任务,主线程等待全部完成 模拟高并发请求,确保所有线程同时开始执行

代码示例:主线程等待子线程完成

下面是一个简单的例子,演示如何使用 CountDownLatch 让主线程等待三个工作线程完成任务:

在Android 在Android

本文档主要讲述的是在Android-Studio中导入Vitamio框架;介绍了如何将Vitamio框架以Module的形式添加到自己的项目中使用,这个方法也适合导入其他模块实现步骤。希望本文档会给有需要的朋友带来帮助;感兴趣的朋友可以过来看看

在Android 0 查看详情 在Android

import java.util.concurrent.CountDownLatch;public class CountDownLatchExample {    public static void main(String[] args) throws InterruptedException {        int threadCount = 3;        CountDownLatch latch = new CountDownLatch(threadCount);        for (int i = 1; i  {                System.out.println(Thread.currentThread().getName() + " 正在执行任务...");                try {                    Thread.sleep(2000); // 模拟耗时操作                } catch (InterruptedException e) {                    Thread.currentThread().interrupt();                }                System.out.println(Thread.currentThread().getName() + " 任务完成");                latch.countDown(); // 完成任务,计数器减一            }, "Worker-" + i).start();        }        System.out.println("主线程等待所有子线程完成...");        latch.await(); // 阻塞主线程,直到计数器为0        System.out.println("所有子线程已完成,主线程继续执行。");    }}

输出结果大致如下:

主线程等待所有子线程完成...Worker-1 正在执行任务...Worker-2 正在执行任务...Worker-3 正在执行任务...Worker-1 任务完成Worker-2 任务完成Worker-3 任务完成所有子线程已完成,主线程继续执行。

带超时的等待

如果不想无限等待,可以使用带超时参数的 await(long timeout, TimeUnit unit) 方法:

boolean finished = latch.await(5, TimeUnit.SECONDS);if (finished) {    System.out.println("所有任务在规定时间内完成");} else {    System.out.println("等待超时,部分任务可能未完成");}

这种方法适用于对响应时间有要求的场景,避免程序因某个线程卡住而一直阻塞。

基本上就这些。只要理解了“计数器减到零才放行”的逻辑,CountDownLatch 就很容易掌握。关键在于合理设置初始计数值,并确保每个任务完成后都调用 countDown(),否则会导致 await() 永远无法返回。

以上就是在Java中如何使用CountDownLatch实现线程同步的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/725679.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
iPhone 12微信无法发送图片解决方法
上一篇 2025年11月24日 17:35:53
es文件浏览器官网官方网址地址__es文件浏览器官方下载地址最新版
下一篇 2025年11月24日 17:35:59

相关推荐

发表回复

登录后才能评论
关注微信