并发工具之计数器CountDownLoach

CountDownLatch是一个同步计数器

作用:用于协调多个线程之间的同步,让一个线程线程等待其他线程执行完以后再执行。

初始化时,传入一个需要计数的线程等待数。

CountDownLatch总共有两个方法: await(): 阻塞当前线程,当其他线程将计数countDown()为0时,线程开始执行 countDown() : 负责计数器减1

例如:主线程等待其他线程执行完,再执行其他线程

public class CountDownLatchDemo { 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表示计数器