CountDownLatch类

1.简述                                                   

  CountDownLatch是Java1.5之后引入的Java并发工具类(闭锁的一个实现),放在java.util.concurrent包下。用给定的计数初始化CountDownLatch。由于调用了countDown方法,所以在当前计数到达零之前,await方法会一直受阻塞。之后,会释放所有等待的线程,await的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。如果需要重置计数,请考虑使用CyclicBarrier。

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

  闭锁(Latch):一种同步方法,可以延迟线程的进度直到线程到达某个终点状态。

  其他的N个线程必须引用闭锁对象,因为他们需要通知CountDownLatch对象,他们已经完成了各自的任务,这种机制就是通过countDown()方法来完成的。

  CountDownLatch优点

  • 对使用者而言,你只需要传入一个int型变量控制任务数量即可,至于同步队列的出队入队维护,state变量值的维护对使用者都是透明的,使用方便。

  CountDownLatch缺点

  • CountDownLatch设置了state后就不能更改,也不能循环使用。

  CountDownLatch使用场景

  • 适用于一个任务的执行需要等待其他任务执行完毕,方可执行的场景。

2.CountDownLatch主要方法                                         

  CountDownLatch的主要方法

  • getCount():获取当前count的值。
  • wait():让当前线程在此CountDownLatch对象上等待,可以中断。与notify()、notifyAll()方法对应。
  • await():让当前线程等待此CountDownLatch对象的count变为0,可以中断。
  • await(timeout,TimeUnit):让当前线程等待此CountDownLatch对象的count变为0,可以超时、可以中断。
  • countDown():使此CountDownLatch对象的count值减1(无论执行多少次,count最小值为0)。

  注意

  • wait()方法是从Object类继承来的。
  • 无论执行多少次countDown()方法,count最小值为0,不会变成负数。

3.CountDownLatch使用                                           

  CountDownLatch的使用示例

CountDownLatch类
public class Test {
    public static void main(String[] args) throws Exception {
        /*创建CountDownLatch实例,计数器的值初始化为5*/
        final CountDownLatch downLatch = new CountDownLatch(5);
        /*创建三个线程,每个线程等待2s,表示执行比较耗时的任务*/
        for(int i = 0;i < 5;i++){
            new Thread(new Runnable() {
                public void run() {
                    try {
                        Thread.sleep(2000);
                        System.out.println(String.format("线程%s已完成", Thread.currentThread().getName()));
                        /*任务完成后调用CountDownLatch的countDown()方法,进行减1*/
                        downLatch.countDown();
                    }catch (InterruptedException e){
                        e.printStackTrace();
                    }
                }
            }).start();
        }
        /*主线程调用await()方法,等到其他五个线程执行完后才继续执行*/
        downLatch.await();
        System.out.print("所有线程都已经执行完成,继续运行主线程逻辑");
    }
}
View Code

4.总结                                                   

  CountDownLatch方法总结

  • await():等待count减少至0,或者被中断。
  • await(timeout,timeUnit):等待count减少至0,或者超时,或者被中断。
  • countDown():count值减1。
上一篇:并发编程:CountDownLatch


下一篇:js(react)60s 验证码倒计时方法