随笔记录 CountDownLatch的使用

Java并发工具类 - CountDownLatch

 介绍

CountDownLatch能够使一个或多个线程等待其他线程完成各自的工作后再执行某个操作。

方法说明：

public CountDownLatch(int count); //指定计数的次数，只能被设置1次 public void countDown();          //调用此方法则计数减1 public void await() throws InterruptedException   //调用此方法会一直阻塞当前线程，直到计时器的值为0，除非线程被中断。 Public Long getCount();           //得到当前的计数 Public boolean await(long timeout, TimeUnit unit) //调用此方法会一直阻塞当前线程，直到计时器的值为0，除非线程被中断或者计数器超时，返回false代表计数器超时。

使用场景

获取一批数据----每条消息异步处理发送-----计算一批数据发送完的时间。

代码

1、给CountDownLatch对象设置一个初始的数字作为计数值

2、其他的任务执行完自己的任务后调用同一个CountDownLatch对象上的countDown()方法，减少计数

3、CountDownLatch对象的await()方法会阻塞，直到这个计数器的计数值被其他的线程减为0为止。