一个线程等待
CountDownLatch使用其await()等待其他线程完成(使用减值为0来判断是否完成)。
是一个线程等待多个线程(1-N)的锁工具。
以下为实例代码:
package com.common; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.Executors; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class CountdownLatchTest extends Thread { public final int countThd = 10; public CountDownLatch latch = new CountDownLatch(countThd); public static void main(String[] args) { CountdownLatchTest one = new CountdownLatchTest(); one.start(); System.out.println("^^^^^^^^mainmianmian^^^^^^^^^"); } public void run() { synchronized (this) { try { System.out.println("GoGoGoGoGoGoGoTOWork"); //Executor executor = Executors.newCachedThreadPool(); for(int i=0;i<this.countThd;i++) { ChildrenThread childt = new ChildrenThread(this.latch,i); Thread each = new Thread(childt); each.start(); //executor.execute(childt); } latch.await(); System.out.println("GoGoGoGoGoGoGoHomeNow"); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //workForever(); } public void workForever() { } class ChildrenThread implements Runnable { CountDownLatch latch; int num; public ChildrenThread(CountDownLatch latch,int num) { this.latch = latch; this.num = num; } @Override public void run() { // TODO Auto-generated method stub try { System.out.println("**********have a rest "+num); Thread.sleep(1000); System.out.println("----------go back to work "+num); latch.countDown(); //CountdownLatchTest.this.latch.countDown(); //System.out.println("%%%%%%%%%%I want to go home"); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
讲述的是一个实习小弟只能等其他员工都改完活才能回家的故事 ,Yes,he is me.
相关推荐
《java并发编程》中CountDownLatch和CyclicBarrier用法实例大全,几乎包含了所有重要的用法
主要介绍了Java CountDownLatch完成异步回调实例详解的相关资料,需要的朋友可以参考下
主要介绍了JAVA CountDownLatch(倒计时计数器)用法实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
全部代码出自电子工业出版社夏先波的《Java JDK实例宝典》一书,本书以J2SE 5.0为开发环境,选取Java应用的典型实例,循序渐进地介绍了Java语言的各种开发方法和技巧,实例代码注释详细规范,思路清晰。 第1章 ...
主要介绍了Java中CountDownLatch进行多线程同步详解及实例代码的相关资料,需要的朋友可以参考下
主要介绍了Java多线程编程之CountDownLatch同步工具使用实例,需要的朋友可以参考下
主要介绍了java CountDownLatch的相关资料,文中示例代码非常详细,帮助大家理解和学习,感兴趣的朋友可以了解下
主要介绍了Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解的相关资料,需要的朋友可以参考下
有以下类的实例: ThreadPool ScheduledThread CyclicBarrier BlockingQueue CountDownLatch FutureTask CompletionService Semaphore
Java并发工具包实例,包含AQS,LOCK,countdownlatch ,atomic原子类等实例
Concurrent下的例子,涵盖了大部分常用类 例如BlockingQueue、CountDownLatch、CyclicBarrier、Exchanger、ExecuteService、lock、timeutil等
同步控制是并发程序必不可少的重要手段,本文我们将通过重入锁、读写锁、信号量、倒计数器和循环栅栏以及他们的实例来介绍Java并发程序中的同步控制。 目录线程安全 Thread Safety重入锁 ReentrantLock读写锁 ...
CountDownLatch:可以使一个或多个线程等待一组事件发生 FutureTask *应用场景 (1)用作异步任务使用,且可以使用get方法获取任务的结果 (2)用于表示一些时间较长的计算 状态 ...
14.6.2 Semaphore与CountDownLatch258 14.6.3 FutureTask259 14.6.4 ReentrantReadWriteLock259 第15章 原子变量与非阻塞同步机制261 15.1 锁的劣势261 15.2 硬件对并发的支持262 15.2.1 比较并交换263 ...
25 JAVA8 与元数据.................................................................................................................................25 2.4. 垃圾回收与算法 .................................
synchronized关键字加在静态方法和实例方法的区别; 用锁的注意点; cas机制可能导致的问题ABA,什么是ABA; 程序开多少线程合适; 实现一下DCL(双重检查锁) stream 和 parallelStream区别; 实现一个阻塞队列(用...
分布式计算的原语,例如AtomicLong , AtomicReference和CountDownLatch 。 Hazelcast数据结构在内存中,经过高度优化,并提供了非常低的延迟。 对于IMap上的单个get或put操作,通常可以预期往返时间不到100微秒。...