闭锁(Latch)
闭锁(Latch):一种同步工具类,可以延迟线程的进度直到其到达终止状态。其作用相当于一扇门,这扇门打开之前,所有线程的将被阻塞在门前,只有在门打开后,所有的线程才能通过。并且门(闭锁)的状态是一次性的(栅栏则是可控),只要门一打开,就不能再关闭。闭锁可以用来确保某些活动直到其它活动都完成后才继续执行。
CountDownLatch是java.util.concurrent包里关于闭锁的一种实现,其API如下:
public CountDownLatch(int count)
// 使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断
public void await() throws InterruptedException
// 使当前线程在锁存器倒计数至零之前一直等待,除非线程被 中断或超出了指定的等待时间。
public boolean await(long timeout, TimeUnit unit) throws InterruptedException
// 倒计数
public void countDown()
// 返回当前计数
public long getCount()
上代码(JCIP5-5加上注释和main()):
/** * TestHarness Using CountDownLatch for starting and stopping threads in timing * tests * * @author Brian Goetz and Tim Peierls * @author Modified by alchimie */ public class TestHarness { public long timeTasks(int nThreads, final Runnable task) throws InterruptedException { // 起始门 final CountDownLatch startGate = new CountDownLatch(1); // 终止门 final CountDownLatch endGate = new CountDownLatch(nThreads); for (int i = 0; i < nThreads; i++) { Thread t = new Thread() { public void run() { try { System.out.println("线程" + Thread.currentThread().getName() + "等待执行"); // 线程等待闭锁打开 startGate.await(); try { task.run(); } finally { endGate.countDown(); } } catch (InterruptedException ignored) { } } }; t.start(); } long start = System.nanoTime(); // 加入一小段等待时间让所有线程就绪 Thread.sleep(100); startGate.countDown(); System.out.println("线程" + Thread.currentThread().getName() + "等待"); // 主线程等待所有子线程运行结束 endGate.await(); System.out.println("线程" + Thread.currentThread().getName() + "执行"); long end = System.nanoTime(); return end - start; } public static void main(String args[]) { TestHarness th = new TestHarness(); try { long time = th.timeTasks(5, new Thread(new Runnable() { public void run() { System.out.println("线程" + Thread.currentThread().getName() + "执行完毕"); } })); System.out.println("统计时间" + time); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
执行结果:
线程Thread-1等待执行
线程Thread-4等待执行
线程Thread-3等待执行
线程Thread-2等待执行
线程Thread-5等待执行
线程main等待
线程Thread-1执行完毕
线程Thread-5执行完毕
线程Thread-2执行完毕
线程Thread-3执行完毕
线程Thread-4执行完毕
线程main执行
统计时间100455504
相关推荐
java并发编程实战源码 附有本书所有源码,maven 导入 eclipse或idea
读书笔记-Java并发编程实战-基础篇
这就是最正宗的《Java 并发编程实战》带目录 用福昕阅读器打开查看特别的清晰
Java 并发编程实战.pdf 目录齐全
java并发编程实战 pdf
62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java并发编程实战62-Java...
深入讲解java并发编程技术,多线程、锁以及java内存模型等
第1章 简介 1.1 并发简史 1.2 线程的优势 1.2.1 发挥多处理器的强大能力 1.2.2 建模的简单性 1.2.3 异步事件的简化处理 1.2.4 响应更灵敏的用户界面 1.3 线程带来的风险 1.3.1 安全性问题 1.3.2 活跃性...
JAVA并发编程实践中文版 英文版 原书源码 带书签 java_concurrency_in_practice.pdf 英文版还是不错的,但是中文版的译者典型的没有技术功底,介绍上说什么专家, 翻译的非常差劲,有些句子都不通顺,都不知道自己去...
《Java并发编程实战》个人读书笔记,非常详细: 1 简介 2 线程安全性 3 对象的共享 4 对象的组合 5 基础构建模块 6 任务执行 7 取消与关闭 8 线程池的使用 9 图形用户界面应用程序 10 避免活跃性危险 11 性能与可...
java并发编程实践笔记java并发编程实践笔记java并发编程实践笔记java并发编程实践笔记
java并发编程与实践是java高并发的分析文档,分析并介绍了高并发的解决方案。
《java并发编程实战》读书笔记-第3章-对象的共享,脑图形式,使用xmind8制作 包括可见性、发布与逸出、线程封闭、不可变性、安全发布等内容
《java并发编程实战》读书笔记-第2章-线程安全性,脑图形式,使用xmind8制作 包括引言、线程安全性定义、原子性、加锁机制、使用锁保护状态、活跃性与性能等内容
《java并发编程实战》读书笔记-第3章-对象的共享,脑图形式,使用xmind8制作 包括线程安全类设计、实例封闭、线程安全性委托、现有线程安全类中添加功能和文档化同步策略等内容
java并发编程实战高清版pdf自用,分享给大家
JAVA并发编程实战,JAVA并发编程实战2本打包!
java并发编程实战pdf学习笔记 总结了重要的知识点
JAVA并发编程实战.pdf-详细介绍了线程并发的机制的