import java.util.concurrent.CountDownLatch;
/**
* CountDownLatch 闭锁演示
* 闭锁的作用相当于一扇门:在闭锁到达结束状态(getCount()=0)前,这扇门一直是关闭的,并且没有任何线程能通过。
* 当到达结束状态时,这扇门会打开并允许所有的线程通过(可以继续执行await()之后的代码)。
* 当闭锁到达结束状态后,将不会再改变状态,因此这扇门将永远保持打开状态。
* **/
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 thread = new Thread(){
public void run(){
try {
System.out.println("Before:S="+startGate.getCount()+" E="+endGate.getCount());
startGate.await();//使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断。
System.out.println("After:S="+startGate.getCount()+" E="+endGate.getCount());
try {
System.out.println("task run!");
task.run();
} finally{
System.out.println("End Gate countDown()");
endGate.countDown();
}
} catch (InterruptedException e) {}
}
};
thread.start();
}
long start = System.nanoTime();//返回最准确的可用系统计时器的当前值,以毫微秒为单位。
System.out.println("开启启动门!");
startGate.countDown();//递减锁存器的计数,如果计数到达零,则释放所有等待的线程。
endGate.await();//使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断。
System.out.println("End Gate await()");
long end = System.nanoTime();
return end-start;
}
public static void main(String[] args) {
MyThread thread=new MyThread("线程A");
TestHarness testHarness = new TestHarness();
try {
long time = testHarness.timeTasks(10, thread);
System.out.println("It's cost time:"+time);
} catch (Exception e) {
System.out.println("Exception Accured!");
}
}
}
分享到:
相关推荐
mybaits 多线程 实现数据批量插入 (运用CountDownLatch实现闭锁) 1、mybatis批处理 2、数据分批量查询 3、数据分批量插入
《java并发编程》中CountDownLatch和CyclicBarrier用法实例大全,几乎包含了所有重要的用法
在我们JDK的并发包中,提供了几个非常有用的并发工具类,比如:CountDownLatch 闭锁、CyclicBarrier 同步屏障、Semaphore 信号量,在线程之间交换数据的一种方式 Exchanger,赶紧操练起来。 2、CountDownLatch 闭锁 ...
利用 CountDownLatch 类实现线程同步,而不用回调机制。详见我的博文 http://blog.csdn.net/kroclin/article/details/37956949
递减锁存器CountDownLatch的使用以及注意事项!
目录 CountDownLatch是什么? CountDownLatch如何工作? 在实时系统中的应用场景 应用范例 常见的面试题 代码样例
在网上找的一个CountDownLatch的学习demo,感觉很不错,就摘抄过来了
CountDownLatch与thread.join()的区别
NULL 博文链接:https://cpjsjxy.iteye.com/blog/2272451
CountDownLatch Demo
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf
CountDownLatch计数器闭锁是一个能阻塞主线程,让其他线程满足特定条件下主线程再继续执行的线程同步工具。 Latch闭锁的意思,是一种同步的工具类。类似于一扇门:在闭锁到达结束状态之前,这扇门一直是关闭着的,不...
并发编程之CountDownLatch
尚硅谷_JUC线程高级_CountDownLatch 闭锁 ·6. 实现 Callable 接口 ·7. 尚硅谷_JUC线程高级_同步锁 Lock ·8. 尚硅谷_JUC线程高级_生产者消费者案例-虚假唤醒 ·9. 尚硅谷_JUC线程高级_Condition 线程通信 ·10. ...
1.2 CountDownLatch概述 CountDownLatch的基本用法 2.1 创建CountDownLatch对象 2.2 await()方法 2.3 countDown()方法 实现多线程任务的同步 3.1 场景介绍 3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 ...
CountDownLatch是什么? CountDownLatch是在java1.5被引入的,跟它一起被引入的并发工具类还有CyclicBarrier、Semaphore、ConcurrentHashMap和BlockingQueue,它们都存在于java.util.concurrent包下。CountDownLatch...
Java并发编程一CountDownLatch、CyclicBarrier、Semaphore初使用 CountDownLatch、CyclicBarrier、Semaphore这些线程协作工具类是基于AQS的,看完这篇博客后可以去看下面这篇博客,了解它们是如何实现的。 Java并发...
CountDownLatch是一个同步工具类,它通过一个计数器来实现的,初始值为线程的数量。每当一个线程完成了自己的任务,计数器的值就相应得减1。当计数器到达0时,表示所有的线程都已执行完毕,然后在等待的线程就可以恢复...
其实我自认为CountDownLatch类是进入AQS世界一个非常好非常好的通道,因此写完这篇文章,我打算再写一篇关于CountDownLatch源码的文章。 1 原理简介 CountDownLatch原理可以用下图进行表示: 这里注意一下: 每个...