20.CountDownLatch闭锁

①Java5.0在java.util.concurrent包中提供了多种并发容器类来改进同步容器的性能。

②CountDownLatch一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

③闭锁可以延迟线程的进度直到其到达终止状态，闭锁可以用来确保某些活动直到其他活动都完成才继续执行：

---> 确保某个计算在其需要的所有资源都被初始化之后才继续执行；

---> 确保某个服务在其依赖的所有其他服务都已经启动之后才启动；

---> 等待直到某个操作所有参与者都准备就绪再继续执行。

import java.util.concurrent.CountDownLatch; /** * CountDownLatch:闭锁，在完成某些运算时，只有其他所有线程的运算全部完成，当前运算才继续执行 * 比如：计算多线程的执行时间。 */ public class TestCountDownLatch { public static void main(String[] args) { /** * 刚开始初始化变量为5，底层就是维护了一个变量，当每一个线程执行CountDownLatch的时候， * 变量值减1，当值为0的时候，才可以继续执行 */ final CountDownLatch latch = new CountDownLatch(5); LatchDemo ld = new LatchDemo(latch); long start = System.currentTimeMillis(); for (int i = 0; i < 5; i++) { new Thread(ld).start(); } try { latch.await(); } catch (InterruptedException e) { e.printStackTrace(); } long end = System.currentTimeMillis(); System.out.println("耗费时间为："+(end - start)); } } class LatchDemo implements Runnable{ private CountDownLatch latch; public LatchDemo(CountDownLatch latch) { this.latch = latch; } public void run() { synchronized(this){ try { for (int i = 0; i < 50000; i++) { if(i % 2 ==0){ System.out.println(i); } } } catch (Exception e) { e.printStackTrace(); }finally{ latch.countDown();//值递减1，必须执行 } } } }

结果：

49984 49986 49988 49990 49992 49994 49996 49998 耗费时间为：1015 例子：比如不同类型的商品都有库存，要算出各个库存的值，最终要算出总得值。