new CountDownLatch(1)这个有什么用

时间: 2024-05-18 17:09:34 浏览: 96

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`并行执行这些部分，然后主线程等待所有部分完成后再进行汇总，这样可以显著提高整体执行效率。

CountDownLatch是Java中的一个并发工具类，它可以用来协调多个线程之间的同步操作。new CountDownLatch(1)表示创建了一个CountDownLatch对象，它的计数器初始值为1。在某些情况下，我们需要等待某个操作完成后才能进行下一步操作，这时可以使用CountDownLatch来实现。例如，我们希望某个线程在执行完一些操作后再继续执行，可以将这个CountDownLatch传递给该线程，并在该线程中调用await()方法进行等待，直到计数器的值变为0后才会继续执行。而在其他线程中，如果需要通知该线程继续执行，可以调用CountDownLatch对象的countDown()方法将计数器减1。当计数器减为0时，await()方法就会返回。

阅读全文

new CountDownLatch(1)这个有什么用

相关推荐

Java并发编程：CountDownLatch深度解析与应用示例

Java并发工具：CountDownLatch实现多线程同步解析Excel

private volatile CountDownLatch countDownLatch = new CountDownLatch(1);

CountDownLatch latch = new CountDownLatch(10);什么意思

private volatile CountDownLatch countDownLatch = new CountDownLatch(1);如何重置

final CountDownLatch latch = new CountDownLatch

final CountDownLatch finishLatch = new CountDownLatch(1);

CountDownLatch countDownLatch = new CountDownLatch(4);

CountDownLatch countDownLatch = new CountDownLatch(length);

CountDownLatch countDownLatch=new CountDownLatch(count);

final CountDownLatch eventLatch = new CountDownLatch(1);是做什么的的

final CountDownLatch finishLatch = new CountDownLatch(5)什么作用

final CountDownLatch countDownLatch = new CountDownLatch(messageCount);

CountDownLatch2 countDownLatch = new CountDownLatch2(messageCount);

CountDownLatch latch=new CountDownLatch();

new CountDownLatch(1).await()

final CountDownLatch countDownLatch = new CountDownLatch(EXECUTE_COUNT);

new CountDownLatch(4)

CountDownLatch countDownLatch = new CountDownLatch(data.size());

最新推荐

CountDownLatch源码解析之await()

A级景区数据文件json

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

管理建模和仿真的文件

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

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

Naruto爱好者必备CLI测试应用

"互动学习：行动中的多样性与论文攻读经历"

【强化学习损失函数探索】：奖励函数与损失函数的深入联系及优化策略

如何在Springboot后端项目中实现前端的多人视频会议功能，并使用Vue.js与ElementUI进行界面开发？