@[toc]

(计数器)CountDownLatch

CountDownLatch 类位于java.util.concurrent包下，利用它可以实现类似计数器的功能。比如有一个任务A，它要等待其他4个任务执行完毕之后才能执行，此时就可以利用CountDownLatch来实现这种功能了。CountDownLatch是通过一个计数器来实现的，计数器的初始值为线程的数量。每当一个线程完成了自己的任务后，计数器的值就会减1。当计数器值到达0时，它表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。

**countDownLatch是在java1.5被引入，跟它一起被引入的工具类还有CyclicBarrier、Semaphore、concurrentHashMap和BlockingQueue。
存在于java.util.concurrent包下。**

public class CountDownLatchExample {
   // 循环次数
  private static final int FOR_NUMBER = 5;


   public static void main(String[] args) {

       // 查询数据
       for (int i = 0; i < FOR_NUMBER; i++) {
           new Thread(() -> {
               System.out.println("查询第:\t" + Thread.currentThread().getName() + "张表数据完成!");
          }, String.valueOf(i)).start();
      }


       System.out.println("查询完毕");

  }
}

可以看到，还有数据没查询完成他就体检进行查询完毕的操作了。那如果在实际开发过程中，就等于数据还没处理完成就返回用户数据了。这并不是我们想要的结果。

那么刚才也有说CountDownLatch是阻塞一个或多个线程等待其他线程完成操作，那么我们试一下。

public class CountDownLatchExample {
   // 循环五次
  private static final int FOR_NUMBER = 5;

  // 实例化定义一个CountDownLatch需要减少的总次数
  private static CountDownLatch countDownLatch = new CountDownLatch(5);


   public static void main(String[] args) {

       // 查询数据
       for (int i = 0; i < FOR_NUMBER; i++) {
           new Thread(() -> {
               System.out.println("查询第:\t" + Thread.currentThread().getName() + "张表数据完成!");

               // 执行完 查询 然后进行递减操作 每次减1
               countDownLatch.countDown();
          }, String.valueOf(i)).start();
      }

       try {
           countDownLatch.await(); // await()方法起到阻塞的作用，直到计数器值等于0
      } catch (InterruptedException e) {
           e.printStackTrace();
      }


       System.out.println("查询完毕");

  }
}

底层实现

有参构造 传的是int 类型数据

await方法 ： await()方法起到阻塞的作用，直到计数器值等于0才能走下面逻辑

countDown 方法 ：如果当前计数大于零，则将其递减。
*如果新计数为零，则所有等待线程都将重新启用
线程调度目的。 如果当前计数等于零，则不会发生任何事情。

getCount 方法 ：返回当前计数