CountDownLoach用法

CountDownLatch是通过一个计数器来实现的，用于协调多个线程之间的同步，让一个线程线程等待其他线程执行完以后再执行。
当new 一个CountDownLatch对象的时候需要设置计数，每当一个线程完成自己的任务后，计数器的值就会减1。由于调用了 countDown() 方法，当CountDownLatch值变为0时之前，调用 await（） 方法会一直受阻塞,当CountDownLatch值变为0时之后，就表示所有的线程均已经完成了任务，然后就可以恢复等待的线程继续执行了。

CountDownLatch总共有两个方法：

• await(): 阻塞当前线程，当其他线程将计数countDown()为0时，线程开始执行
• countDown() : 负责计数器减1

先是不使用countDownLatch多多线程

package com.learn.wecath.thread;
import java.util.concurrent.CountDownLatch;

public class CountDownLacthController {

    public static void main(String[] args) throws InterruptedException {
        System.out.println("主线程开始执行");
        test();
        System.out.println("主线程结束执行");
    }

    public static void test() {
        new Thread(() -> {
            System.out.println("新线程01执行");
        }).start();
        new Thread(() -> {
            System.out.println("新线程02执行");
        }).start();
        new Thread(() -> {
            System.out.println("新线程03执行");
        }).start();
    }
}

执行结果：

主线程开始执行
新线程02执行
主线程结束执行
新线程01执行
新线程03执行

主线程等待其他线程执行完，再执行其他线程

package com.learn.wecath.thread;
import java.util.concurrent.CountDownLatch;

public class CountDownLacthController {
    public static CountDownLatch countDownLatch = new CountDownLatch(3);

    public static void main(String[] args) throws InterruptedException {
        System.out.println("主线程开始执行");
        test();
        countDownLatch.await();
        System.out.println("主线程结束执行");
    }

    public static void test() {
        new Thread(() -> {
            System.out.println("新线程01执行");
            countDownLatch.countDown();
        }).start();
        new Thread(() -> {
            System.out.println("新线程02执行");
            countDownLatch.countDown();
        }).start();
        new Thread(() -> {
            System.out.println("新线程03执行");
            countDownLatch.countDown();
        }).start();
    }
}

执行结果如下：

主线程开始执行
新线程01执行
新线程02执行
新线程03执行
主线程结束执行

CountDownLatch使用了AQS的共享锁， state表示计数器