Semaphore.acquire():Acquires a permit from this semaphore, blocking until one is available
与Executors.newFixedThreadPool( 2 )作用相似
CyclicBarrier.await(): Waits until all parties have invoked await on this barrier.
CountDownLatch.await(): Causes the current thread to wait until the latch has counted down to zero
/** * CountDownLatch.await(): Causes the current thread to wait until the latch has counted down to zero, * unless the thread is interrupted. * @author timeriver.wang * @date 2014-03-10 10:39:10 AM */ public class CountdownLatchTest { public static void main( String[] args ) { ExecutorService service = Executors.newCachedThreadPool(); final CountDownLatch cdOrder = new CountDownLatch( 1 ); final CountDownLatch cdAnswer = new CountDownLatch( 3 ); for ( int i = 0; i < 3; i++ ) { Runnable runnable = new Runnable() { public void run() { System.out.println( "线程" + Thread.currentThread().getName() + "正准备接受命令" ); try { cdOrder.await(); System.out.println( "线程" + Thread.currentThread().getName() + "已接受命令" ); Thread.sleep( (long) ( 1000 ) ); } catch ( InterruptedException e ) { e.printStackTrace(); } System.out.println( "线程" + Thread.currentThread().getName() + "回应命令处理结果" ); cdAnswer.countDown(); } }; service.execute( runnable ); } service.shutdown(); try { // make sure thread all have start. can using t.join() Thread.sleep( (long) ( 1000 ) ); System.out.println( "线程" + Thread.currentThread().getName() + "即将发布命令" ); cdOrder.countDown(); System.out.println( "线程" + Thread.currentThread().getName() + "已发送命令,正在等待结果" ); cdAnswer.await(); System.out.println( "线程" + Thread.currentThread().getName() + "已收到所有响应结果" ); } catch ( Exception e ) { e.printStackTrace(); } } }
相关推荐
CountDownLatch与thread.join()的区别
countdownlatch-example-sourcecode.zip
《java并发编程》中CountDownLatch和CyclicBarrier用法实例大全,几乎包含了所有重要的用法
利用 CountDownLatch 类实现线程同步,而不用回调机制。详见我的博文 http://blog.csdn.net/kroclin/article/details/37956949
递减锁存器CountDownLatch的使用以及注意事项!
目录 CountDownLatch是什么? CountDownLatch如何工作? 在实时系统中的应用场景 应用范例 常见的面试题 代码样例
在网上找的一个CountDownLatch的学习demo,感觉很不错,就摘抄过来了
mybaits 多线程 实现数据批量插入 (运用CountDownLatch实现闭锁) 1、mybatis批处理 2、数据分批量查询 3、数据分批量插入
CountDownLatch Demo
NULL 博文链接:https://cpjsjxy.iteye.com/blog/2272451
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf
并发编程之CountDownLatch
主要介绍了JAVA CountDownLatch与thread-join()的区别解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
1.2 CountDownLatch概述 CountDownLatch的基本用法 2.1 创建CountDownLatch对象 2.2 await()方法 2.3 countDown()方法 实现多线程任务的同步 3.1 场景介绍 3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 ...
CountDownLatch是一个同步工具类,它通过一个计数器来实现的,初始值为线程的数量。每当一个线程完成了自己的任务,计数器的值就相应得减1。当计数器到达0时,表示所有的线程都已执行完毕,然后在等待的线程就可以恢复...
Java并发编程一CountDownLatch、CyclicBarrier、Semaphore初使用 CountDownLatch、CyclicBarrier、Semaphore这些线程协作工具类是基于AQS的,看完这篇博客后可以去看下面这篇博客,了解它们是如何实现的。 Java并发...
Thread.sleep((long)(Math.random()*100)); //随机分配时间,即运动员完成时间 System.out.println("Play"+id+" arrived."); }catch (InterruptedException e) { // TODO: handle exception e.printStackTrace...
其实我自认为CountDownLatch类是进入AQS世界一个非常好非常好的通道,因此写完这篇文章,我打算再写一篇关于CountDownLatch源码的文章。 1 原理简介 CountDownLatch原理可以用下图进行表示: 这里注意一下: 每个...
TestSemaphore、TestLock、TestCyclicBarrier、CountdownLatchTest、LRUCache 博文链接:https://uule.iteye.com/blog/1543958