Java并發(fā)多線程編程之CountDownLatch的用法

更新時(shí)間：2023年06月19日 10:18:36 作者：小志的博客

這篇文章主要介紹了Java并發(fā)多線程編程之CountDownLatch的用法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

一、CountDownLatch概述

讓一些線程阻塞直到另外一些完成后才被喚醒。

CountDownLatch主要有兩個(gè)方法：

（1）、當(dāng)一個(gè)或多個(gè)線程調(diào)用await方法時(shí),調(diào)用線程會(huì)被阻塞.

（2）、其他線程調(diào)用countDown方法計(jì)數(shù)器減1(調(diào)用countDown方法時(shí)線程不會(huì)阻塞)，當(dāng)計(jì)數(shù)器的值變?yōu)?，因調(diào)用await方法被阻塞的線程會(huì)被喚醒，繼續(xù)執(zhí)行。

二、CountDownLatch代碼示例（模擬員工下班關(guān)門(mén)案例）

模擬公司所有員工都下班后，值班人員鎖門(mén)離開(kāi)公司。

代碼

import java.util.concurrent.CountDownLatch;
/**
 * @description:  模擬員工下班關(guān)門(mén)案例
 * @author: xz
 */
public class CountDownLatchDemo1 {
    public static void main(String[] args) throws InterruptedException {
        closeDoor();
    }
    private static void closeDoor() throws InterruptedException {
        //創(chuàng)建CountDownLatch,初始容量為10，模擬10名員工
        CountDownLatch countDownLatch=new CountDownLatch(10);
        for (int i=1;i<=10;i++){
            new Thread(()->{
                System.out.println(Thread.currentThread().getName() + "\t" + "忙完工作，下班。");
                //計(jì)數(shù)器減1
                countDownLatch.countDown();
            },"員工編號(hào)："+String.valueOf(i)).start();
        }
        //當(dāng)計(jì)數(shù)器的值變?yōu)?,因調(diào)用await方法被阻塞的線程會(huì)被喚醒,繼續(xù)執(zhí)行
        countDownLatch.await();
        System.out.println(Thread.currentThread().getName() + "\t值班人員鎖門(mén)離開(kāi)公司");
    }
}

輸出結(jié)果如下圖：

三、CountDownLatch代碼示例（使用枚舉方式模擬員工下班關(guān)門(mén)案例）

模擬公司所有員工都下班后，值班人員鎖門(mén)離開(kāi)公司。

代碼

import lombok.Getter;
/**
 * @description: 枚舉類(lèi)，定義10名員工
 * @author: xz
 * */
public enum EmpEnum {
    ONE(1, "劉一"),
    TWO(2, "陳二"),
    THREE(3, "張三"),
    FOUR(4, "李四"),
    FIVE(5, "王五"),
    SIX(6, "趙六"),
    SEVEN(7, "孫七"),
    EIGHT(8, "周八"),
    NINE(9, "吳九"),
    TEN(10, "鄭十");
    @Getter
    private int code;//員工編號(hào)
    @Getter
    private String name;//員工名稱(chēng)
    EmpEnum(Integer code, String name) {
        this.code = code;
        this.name = name;
    }
    public static EmpEnum forEach(int index) {
        EmpEnum[] EmpEnums = EmpEnum.values();
        for (EmpEnum epmEnum : EmpEnums) {
            if (index == epmEnum.getCode()) {
                return epmEnum;
            }
        }
        return null;
    }
}

public class CountDownLatchDemo2 {
    public static void main(String[] args) throws InterruptedException {
        closeDoor();
    }
    private static void closeDoor() throws InterruptedException {
        //創(chuàng)建CountDownLatch,初始容量為10，模擬10名員工
        CountDownLatch countDownLatch=new CountDownLatch(10);
        for (int i=1;i<=10;i++){
            new Thread(()->{
                System.out.println(Thread.currentThread().getName() + "\t" + "忙完工作，下班。");
                //計(jì)數(shù)器減1
                countDownLatch.countDown();
            },EmpEnum.forEach(i).getName()).start();
        }
        //當(dāng)計(jì)數(shù)器的值變?yōu)?,因調(diào)用await方法被阻塞的線程會(huì)被喚醒,繼續(xù)執(zhí)行
        countDownLatch.await();
        System.out.println(Thread.currentThread().getName() + "\t值班人員鎖門(mén)離開(kāi)公司");
    }
}

輸出結(jié)果如下圖：