Java CountDownLatch没有count down

时间: 2023-11-01 13:56:43 浏览: 151

Java并发包之CountDownLatch用法.docx

CountDownLatch计数器闭锁是一个能阻塞主线程，让其他线程满足特定条件下主线程再继续执行的线程同步工具。 Latch闭锁的意思，是一种同步的工具类。类似于一扇门：在闭锁到达结束状态之前，这扇门一直是关闭着的，不允许任何线程通过，当到达结束状态时，这扇门会打开并允许所有的线程通过。且当门打开了，就永远保持打开状态。 `CountDownLatch`是Java并发包`java.util.concurrent`中的一个重要工具类，用于实现线程间的同步。它基于计数器的概念，初始化时设置一个非负的计数值，然后通过调用`countDown()`方法来递减这个计数器。主线程或其他线程在调用`await()`方法时会被阻塞，直到计数器归零，所有线程完成其任务，这时`await()`方法返回，阻塞的线程才会继续执行。在上述描述中，`CountDownLatch`被比喻为一扇门，未达到结束状态（计数器未归零）时，门是关闭的，不允许线程通过；当计数器归零，门打开，所有线程都可以通过。这个特性使得`CountDownLatch`非常适合在多线程环境下，用于主线程等待一组子线程完成特定操作后再继续执行。例如，以下场景中`CountDownLatch`的应用非常典型： 1. **多线程读取批量文件**：主线程创建多个子线程读取不同的文件，所有文件读取完成后，主线程进行汇总处理。 2. **多线程读取Excel多个sheet**：主线程启动多个线程读取Excel的不同sheet，所有sheet读取完成后，主线程对结果进行整合。 3. **模拟客人到齐后开饭**：主线程代表主人，子线程代表客人，所有客人都到达后，主线程（主人）宣布开饭。 4. **汽车站出发**：主线程代表汽车，子线程代表乘客，所有乘客都到达后，主线程（汽车）启动。使用`CountDownLatch`时，需要注意以下几点： - **计数器设置**：计数器的初始值应等于需要等待的线程数量，确保准确计数。 - **`countDown()`调用**：每个子线程完成任务后，必须调用`countDown()`，否则计数器可能不会归零，导致主线程等待不结束。 - **异常处理**：为了确保即使在子线程抛出异常时也能正确地调用`countDown()`，通常将`countDown()`放入`try...finally`块中。 - **超时等待**：可以通过`latch.await(timeout, unit)`设置等待的最长时间，如果超时则`await()`方法会返回，即使计数器没有归零。下面是一个模拟乘客登机的`CountDownLatch`使用示例： ```java public class CountDownLatchTest { public static void main(String[] args) throws InterruptedException { System.out.println("南京禄口机场_机长正在等待所有乘客登机"); CountDownLatch latch = new CountDownLatch(3); ExecutorService ex = Executors.newCachedThreadPool(); ex.execute(new ThreadTest1(latch)); ex.execute(new ThreadTest2(latch)); ex.execute(new ThreadTest3(latch)); System.out.println("所有乘客都在赶飞机的路上"); latch.await(); // 等待所有乘客登机完成 System.out.println("南京禄口机场_机长启动飞机起飞"); ex.shutdown(); } static class ThreadTest1 extends Thread { private CountDownLatch latch; public ThreadTest1(CountDownLatch latch) { this.latch = latch; } @Override public void run() { // 模拟乘客1登机 // ... latch.countDown(); // 乘客1登机完成 } } // 同理，创建ThreadTest2和ThreadTest3类 } ``` 在这个例子中，`CountDownLatchTest`的主方法创建了3个线程模拟3位乘客登机，`CountDownLatch`的计数器初始化为3。当所有乘客登机完成后，主线程会继续执行并宣布飞机起飞。 `CountDownLatch`在并行任务拆分和优化执行时间方面非常有用。如果一个任务可以被分解成多个独立部分，可以使用`CountDownLatch`并行执行这些部分，然后主线程等待所有部分完成后再进行汇总，这样可以显著提高整体执行效率。

Java CountDownLatch没有count down时，其他线程将一直等待。CountDownLatch作为一个同步工具，它的主要作用是允许一个或多个线程等待其他线程完成操作后再执行。当没有count down操作时，等待的线程将无法继续执行，而处于一直等待的状态。这可能是因为在代码中缺少了调用countDown方法的地方，或者调用countDown方法的次数与等待的线程数量不匹配。为了避免这种情况，需要确保在适当的位置调用countDown方法以减少CountDownLatch的计数。这样，当计数减少到0时，等待的线程将被唤醒并可以继续执行。

阅读全文

Java CountDownLatch没有count down

相关推荐

Java中CountDownLatch用法解析

CountDownLatch练习

Java中多线程同步类 CountDownLatch

countdownlatch-example-sourcecode.zip

CountDownLatch的内部工作机制分析

【避免并发陷阱】：CountDownLatch错误用法及其后果的深入剖析

Java中的线程池策略配置与调优指南

CountDownLatch new Thread获取异常信息

countdownlatch一个子线程超时shutdown

用Java写上面这个问题

A级景区数据文件json

使用Java编写的坦克大战小游戏.zip学习资料

【python毕设】p073基于Spark的温布尔登特色赛赛事数据分析预测及算法实现_flask(5).zip

C#编写的OPCClient 利用OPCDAAuto.dll

用Python编程实现控制台爱心形状绘制技术教程

毕业设计&课设_会议厅预约管理系统：Java 毕设项目，含前后端登录.zip

AI's prompts

想知道你的模型看到了什么吗？这是一个在新的 YOLO V8 模型上应用 EigenCAM 的包.zip

彩蝶ARP防火墙，很好用！

最新推荐

java使用CountDownLatch等待多线程全部执行完成

CountDownLatch源码解析之await()

Java知识点总结文档

Java异步调用转同步方法实例详解

java实现HttpClient异步请求资源的方法

JHU荣誉单变量微积分课程教案介绍

管理建模和仿真的文件

【实战篇：自定义损失函数】：构建独特损失函数解决特定问题，优化模型性能

如何在ZYNQMP平台上配置TUSB1210 USB接口芯片以实现Host模式，并确保与Linux内核的兼容性？

Naruto爱好者必备CLI测试应用