神刀安全网

[Java并发编程实战] 闭锁 CountDownLatch 实现(含代码)

路漫漫其修远兮,吾将上下而求索。———屈原《离骚》

闭锁

闭锁(latch)是一种 Synchronizer,他可以延迟线程的进度直到线程到达终止状态。

一个闭锁工作起来就像一道大门:直到闭锁达到终点状态之前,门一直是关闭的,没有线程通过,在终点状态到来的时候,门开了,允许所有线程都通过。一旦闭锁到达了终点状态,他就不能够在改变状态了,所以它会永远保持敞开的状态。

闭锁的应用

  • 确保一个计算不会执行,直到它需要的资源被初始化。
  • 确保一个服务不会开始,直到它依赖的服务都已经开始。
  • 等待直到活动的所有部分都为继续处理做好准备。比如王者荣耀需要等待所有玩家准备才能开始。

闭锁的实现

CountDownLatch 是一个灵活的闭锁实现,可以用于上述几种情况,允许一个或者多个线程等待一个事件集的发生。闭锁的状态包括一个计数器,初始为一个正数,表示要等待的事件数。countDown方法对于计数器做减数操作,表示一个事件已经发生了,而 await阻塞方法将阻塞当前线程直到计数器减到零。

CountDownLatch示例

下面举个例子,CountDownLatchTest 创建两个特闭锁对象。第一个是主线程用于判断所有线程启动完毕的闭锁,用于阻塞子线程执行直到所有线程都启动完毕。第二个是子线程执行完毕的闭锁,直到每个线程都执行完毕后,才统计总共运行了多少时间。

import java.util.concurrent.CountDownLatch;  public class CountDownLatchTest{          private static CountDownLatch main_cdl = new CountDownLatch(1);//闭锁1     private static CountDownLatch sub_cdl = new CountDownLatch(5);//闭锁2          public static void main(String[] args) {         //创建五个线程并启动         for(int i = 0; i < 5; i++) {             new Thread(new SubThread()).start();         }                  long start = System.nanoTime();         main_cdl.countDown();//打开闭锁,让五个线程继续执行         try {             sub_cdl.await();//阻塞闭锁,等待五个线程都执行完毕         } catch (InterruptedException e) {             // TODO Auto-generated catch block             e.printStackTrace();         }         long end = System.nanoTime();         System.out.println(end - start);//五个线程总共执行了多长时间     }     //子线程     static class SubThread implements Runnable{         public SubThread() {}         @Override         public void run() {             try {                 main_cdl.await();//阻塞,等待主线程启动所有子线程你                 System.out.println(Thread.currentThread().getName() + ":runing");             } catch (InterruptedException e) {                 // TODO Auto-generated catch block                 e.printStackTrace();             }finally {                 sub_cdl.countDown();//子线程执行完毕,计数器减1             }         }     } } 

执行结果:

[Java并发编程实战] 闭锁 CountDownLatch 实现(含代码)

这里写图片描述

本文到此结束,我们已经直到如何去使用闭锁,和它使用的场景啦。

希望对你有帮助,欢迎关注我!谢谢~

转载本站任何文章请注明:转载至神刀安全网,谢谢神刀安全网 » [Java并发编程实战] 闭锁 CountDownLatch 实现(含代码)

分享到:更多 ()