java-CountDownLatch
CountDownLatch概念
- CountDownLatch是一个同步工具类，用来协调多个线程之间的同步，或者说起到线程之间的通信（而不是用作互斥的作用）。
- CountDownLatch能够使一个线程在等待另外一些线程完成各自工作之后，再继续执行。使用一个计数器进行实现。计数器初始值为线程的数量。当每一个线程完成自己任务后，计数器的值就会减一。当计数器的值为0时，表示所有的线程都已经完成一些任务，然后在CountDownLatch上等待的线程就可以恢复执行接下来的任务。
countDown()方法
public void countDown()
递减锁存器的计数，如果计数到达零，则释放所有等待的线程。如果当前计数大于零，则将计数减少.
await()方法
public boolean await(long timeout,TimeUnit unit) throws InterruptedException
使当前线程在锁存器倒计数至零之前一直等待，除非线程被中断或超出了指定的等待时间。如果当前计数为零，则此方法立刻返回true值。
如果当前计数大于零，则出于线程调度目的，将禁用当前线程，且在发生以下三种情况之一前，该线程将一直出于休眠状态：
由于调用countDown()方法，计数到达零；或者其他某个线程中断当前线程；或者已超出指定的等待时间。
- 如果计数到达零，则该方法返回true值。
- 如果当前线程，在进入此方法时已经设置了该线程的中断状态；或者在等待时被中断，则抛出InterruptedException，并且清除当前线程的已中断状态。
- 如果超出了指定的等待时间，则返回值为false。如果该时间小于等于零，则该方法根本不会等待。
参数：
- timeout-要等待的最长时间
- unit-timeout 参数的时间单位
返回：
- 如果计数到达零，则返回true；如果在计数到达零之前超过了等待时间，则返回false
抛出：
- InterruptedException-如果当前线程在等待时被中断
代码
- 循环10次，将每个线程都依次开启，都是由于
latch.await();的原因，每个线程都处于堵塞状态 - 当循环10次之后，
latch.countDown();这段代码会使锁存器计数减一 - 当锁存器计数为0，会解除堵塞状态
- 此代码在5秒钟后，10个线程被同时解除堵塞状态
- 这就可以模拟了高并发
//初始化CountDownLatch对象，锁存器
CountDownLatch latch = new CountDownLatch(1);
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
try {
//线程执行到这里堵塞hui
latch.await();
//睡眠5秒
Thread.sleep(5000);
System.out.println(Thread.currentThread().getName());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
}
//锁存器计数减一
latch.countDown();
使用场景
- 在一些应用场合中，需要等待某个条件达到要求后才能做后面的事情；同时当线程都完成后也会触发事件，以便进行后面的操作。