并发编程-CountDownLatch

       ‌CountDownLatch是Java并发编程中用于协调多个线程执行顺序的工具类‌，其核心机制是通过一个共享的计数器控制线程的阻塞与唤醒。它通过计数器来实现，初始值为线程的数量。每当一个线程完成了自己的任务，计数器的值就相应得减1。当计数器到达0时，表示所有的线程都已执行完毕，然后在等待的线程就可以恢复执行任务。

        CountDownLatch核心的API见如下：

        CountDownLatch典型的应用场景：

        1、其他线程等待子任务结束

        示例代码演示购买家具流程，发货线程需要等待支付线程和家具组装线程结束后才执行，代码如下：

package com.gingko.thread.countdownlatch;
import java.util.concurrent.CountDownLatch;public class CountDownLatchDemo {public static void main(String[] args) {CountDownLatch countDownLatch = new CountDownLatch(2);//支付线程new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("购买家具，支付金额...");countDownLatch.countDown();}).start();//组装家具线程new Thread(() -> {try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("组装家具...");countDownLatch.countDown();}).start();//发货线程new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}try {countDownLatch.await();//等待【支付线程】和【组装家具线程】运行结束} catch (InterruptedException e) {e.printStackTrace();}System.out.println("商品发货给买家...");}).start();}
}

        程序运行结果如下，符合预期：

        2、并行任务启动‌

        示例代码演示了主线程发出秒杀活动开始的信息，其他10个子线程同时开始抢购商品，代码如下：

package com.gingko.thread.countdownlatch;
import java.util.concurrent.CountDownLatch;public class CountDownLatchDemo2 {public static void main(String[] args) {//count=1等待主线程发令秒杀开始CountDownLatch countDownLatch = new CountDownLatch(1);for (int i = 0; i < 10; i++) {//秒杀活动，10个线程同时抢商品，等待秒杀准时开始new Thread(() -> {try {countDownLatch.await();//等待秒杀活动开始System.out.println(Thread.currentThread().getName() + " 开始抢购商品...");} catch (InterruptedException e) {e.printStackTrace();}}).start();}//秒杀活动开始try {Thread.sleep(1000);System.out.println("秒杀活动开始...");countDownLatch.countDown();} catch (InterruptedException e) {e.printStackTrace();}}
}

        程序运行结果如下，符合预期：