Java并发多线程编程——CountDownLatch

Posted 2022-02-03 小志的博客

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Java并发多线程编程——CountDownLatch相关的知识，希望对你有一定的参考价值。

一、CountDownLatch概述

让一些线程阻塞直到另外一些完成后才被唤醒。
CountDownLatch主要有两个方法：
（1）、当一个或多个线程调用await方法时,调用线程会被阻塞.
（2）、其他线程调用countDown方法计数器减1(调用countDown方法时线程不会阻塞),当计数器的值变为0,因调用await方法被阻塞的线程会被唤醒,继续执行。

二、CountDownLatch代码示例（模拟员工下班关门案例）

模拟公司所有员工都下班后，值班人员锁门离开公司。

代码

import java.util.concurrent.CountDownLatch;

/**
 * @description:  模拟员工下班关门案例
 * @author: xz
 */
public class CountDownLatchDemo1 
    public static void main(String[] args) throws InterruptedException 
        closeDoor();
    

    private static void closeDoor() throws InterruptedException 
        //创建CountDownLatch,初始容量为10，模拟10名员工
        CountDownLatch countDownLatch=new CountDownLatch(10);
        for (int i=1;i<=10;i++)
            new Thread(()->
                System.out.println(Thread.currentThread().getName() + "\\t" + "忙完工作，下班。");
                //计数器减1
                countDownLatch.countDown();
            ,"员工编号："+String.valueOf(i)).start();
        
        //当计数器的值变为0,因调用await方法被阻塞的线程会被唤醒,继续执行
        countDownLatch.await();
        System.out.println(Thread.currentThread().getName() + "\\t值班人员锁门离开公司");

输出结果如下图：

三、CountDownLatch代码示例（使用枚举方式模拟员工下班关门案例）

模拟公司所有员工都下班后，值班人员锁门离开公司。

代码

import lombok.Getter;
/**
 * @description: 枚举类，定义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;//员工编号
    @Getter
    private String name;//员工名称

    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 
        //创建CountDownLatch,初始容量为10，模拟10名员工
        CountDownLatch countDownLatch=new CountDownLatch(10);
        for (int i=1;i<=10;i++)
            new Thread(()->
                System.out.println(Thread.currentThread().getName() + "\\t" + "忙完工作，下班。");
                //计数器减1
                countDownLatch.countDown();
            ,EmpEnum.forEach(i).getName()).start();
        
        //当计数器的值变为0,因调用await方法被阻塞的线程会被唤醒,继续执行
        countDownLatch.await();
        System.out.println(Thread.currentThread().getName() + "\\t值班人员锁门离开公司");