Java并发编程之CountDownLatch解读
概念
- countDownLatch这个类使一个线程等待其他线程各自执行完毕后再执行。
- 是通过一个计数器来实现的,计数器的初始值是线程的数量。每当一个线程执行完毕后,计数器的值就-1,当计数器的值为0时,表示所有线程都执行完毕,然后在闭锁上等待的线程就可以恢复工作了。
源码
countDownLatch类中只提供了一个构造器:
类中有三个方法是最重要的:
1 2 3 4 5 6 | //调用await()方法的线程会被挂起,它会等待直到count值为0才继续执行 public void await() throws InterruptedException { }; //和await()类似,只不过等待一定的时间后count值还没变为0的话就会继续执行 public boolean await( long timeout, TimeUnit unit) throws InterruptedException { }; //将count值减1 public void countDown() { }; |
自定义实现一个CountDownLatch
代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 | public class KaneCountDownLatch { private KaneCountDownLatch.Sync sync; public KaneCountDownLatch( int count) { this .sync = new KaneCountDownLatch.Sync(count); } public void countDown() { this .sync.releaseShared( 1 ); } public void await() { this .sync.acquireShared( 1 ); } class Sync extends AbstractQueuedSynchronizer { public Sync( int count) { this .setState(count); } protected int tryAcquireShared( int arg) { return this .getState() == 0 ? 1 : - 1 ; } protected boolean tryReleaseShared( int arg) { int c; int nextc; do { c = this .getState(); if (c == 0 ) { return false ; } nextc = c - 1 ; } while (! this .compareAndSetState(c, nextc)); return nextc == 0 ; } } } |
测试代码如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 | public class CountDownLatch_Demo { public static void main(String[] args) throws InterruptedException { KaneCountDownLatch latch = new KaneCountDownLatch( 6 ); //计数为6 for ( int i = 0 ; i < 6 ; i++) { new Thread(()->{ System.out.println( "开始准备....." ); latch.countDown(); //计数减一 }).start(); Thread.sleep( 1000 ); } latch.await(); //每个线程执行一次,则-1,在latch为0的时候开始向下运行 这是这些线程都准备就绪,然后去一起干同一件事 //还有一种方式, 将一个活分为多段,每个线程去干一段 // for (int i = 0; i <6 ; i++) { // new Thread(()->{ // latch.countDown(); // 计数减一 // try { // latch.await(); // 阻塞 -- > 0 // System.out.println("线程:"+Thread.currentThread().getName()+"执行完毕"); // } catch (InterruptedException e) { // e.printStackTrace(); // } // }).start(); // } System.out.println( "开始干活...." ); } } |
CountDownLatch和CyclicBarrier区别
- countDownLatch是一个计数器,线程完成一个记录一个,计数器递减,只能只用一次
- CyclicBarrier的计数器更像一个阀门,需要所有线程都到达,然后继续执行,计数器递增,提供reset功能,可以多次使用
到此这篇关于Java并发编程之CountDownLatch解读的文章就介绍到这了,更多相关CountDownLatch解读内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
微信公众号搜索 “ 脚本之家 ” ,选择关注
程序猿的那些事、送书等活动等着你
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符,请将相关资料发送至 reterry123@163.com 进行投诉反馈,一经查实,立即处理!
相关文章
详解mybatis-plus使用@EnumValue注解的方式对枚举类型的处理
这篇文章主要介绍了详解mybatis-plus使用@EnumValue注解的方式对枚举类型的处理,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2020-12-12解决SpringMVC同时接收Json和Restful时Request里有Map的问题
今天小编就为大家分享一篇解决SpringMVC同时接收Json和Restful时Request里有Map的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧2018-08-08解决jackson反序列化失败InvalidFormatException:Can not dese
这篇文章主要介绍了解决jackson反序列化失败InvalidFormatException:Can not deserialize value of type java.util.Date问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-12-12
最新评论