CountDownLatch countDownLatch = new CountDownLatch(4);

时间: 2024-04-29 12:16:35 浏览: 57

并发编程之CountDownLatch

CountDownLatch 并发编程 CountDownLatch 是一个同步的辅助类，它可以允许一个或多个线程等待，直到一组在其它线程中的操作执行完成。它通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减 1。当计数器值到达 0 时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。 CountDownLatch 的主要使用场景包括：实现最大程度的并行性、开始执行前等待 n 个线程完成各自任务、死锁检测等。在实际开发中，CountDownLatch 可以用来实现主线程和子线程之间的通信，例如主线程发送命令启动子线程，子线程全部完成后通知主线程。 CountDownLatch 的工作机理是通过构造函数中的计数值来实现的，这个值只能被设置一次，而且 CountDownLatch 没有提供任何机制去重新设置这个计数值。主线程必须在启动其他线程后立即调用 CountDownLatch.await()方法，其他 N 个线程必须引用闭锁对象，因为他们需要通知 CountDownLatch 对象，他们已经完成了各自的任务。在实际开发中，CountDownLatch 可以用来实现各种并发编程的场景，例如在多线程环境下同时启动多个线程，或者在某些特定的时刻同时启动多个线程等。下面是一个使用 CountDownLatch 实现主线程和子线程通信的示例代码： ```java public class CountDownLatchTest { public static void main(String[] args) { final CountDownLatch cdOrder = new CountDownLatch(1); final CountDownLatch cdAnswer = new CountDownLatch(3); ExecutorService threadPool = Executors.newCachedThreadPool(); for (int i = 0; i < 3; i++) { Runnable runnable = new Runnable() { @Override public void run() { try { System.out.println(Thread.currentThread().getName()+"正在等待命令"); cdOrder.await();//子线程等待 System.out.println(Thread.currentThread().getName()+"接受命令"); Thread.sleep(2000); System.out.println(Thread.currentThread().getName()+"处理完成"); cdAnswer.countDown();//子线程完成任务 } catch (InterruptedException e) { e.printStackTrace(); } } }; threadPool.execute(runnable); } try { System.out.println("主线程发送命令"); cdOrder.countDown();//主线程发送命令 cdAnswer.await();//主线程等待子线程完成任务 System.out.println("主线程恢复执行"); } catch (InterruptedException e) { e.printStackTrace(); } threadPool.shutdown(); } } ``` 在这个示例中，主线程发送命令启动子线程，子线程等待命令后执行任务，子线程完成任务后通知主线程，主线程等待所有子线程完成任务后恢复执行。

CountDownLatch是Java中的一个同步工具类，它可以用来控制线程的执行顺序。在CountDownLatch中，我们可以指定一个初始计数值，当计数值减到0时，等待该计数器的线程将被唤醒。在你提供的代码中，CountDownLatch的初始计数值为4，意味着需要有4个线程调用countDown()方法来将计数值减1，当计数值减到0时，等待该计数器的线程将被唤醒。 CountDownLatch的主要方法有两个： 1. countDown()：将计数值减1。 2. await()：等待计数值减到0。使用CountDownLatch可以实现一些并发场景，例如主线程等待多个子线程执行完毕后再继续执行，或者多个子线程等待某个条件满足后再同时执行等。

阅读全文

CountDownLatch countDownLatch = new CountDownLatch(4);

相关推荐

CountDownLatch的使用

java利用CountDownLatch实现并行计算

CountDownLatch2 countDownLatch = new CountDownLatch2(messageCount);

CountDownLatch countDownLatch = new CountDownLatch(length);

CountDownLatch countDownLatch=new CountDownLatch(count);

final CountDownLatch countDownLatch = new CountDownLatch(messageCount);

private volatile CountDownLatch countDownLatch = new CountDownLatch(1);

final CountDownLatch countDownLatch = new CountDownLatch(EXECUTE_COUNT);

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

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

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

final CountDownLatch latch = new CountDownLatch

CountDownLatch latch=new CountDownLatch();

final CountDownLatch finishLatch = new CountDownLatch(1);

final CountDownLatch finishLatch = new CountDownLatch(5);

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

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

CountDownLatch latch = new CountDownLatch(matchedAmountBridgeList.size()) 用法

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

最新推荐

CountDownLatch源码解析之await()

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

2000-2021年中国科技统计年鉴（分省年度）面板数据集-最新更新.zip

高清艺术文字图标资源，PNG和ICO格式免费下载

管理建模和仿真的文件

DMA技术：绕过CPU实现高效数据传输

SGM8701电压比较器如何在低功耗电池供电系统中实现高效率运作？

mui框架HTML5应用界面组件使用示例教程

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

【数据传输高速公路】：总线系统的深度解析