Java并发多线程编程——CountDownLatch

2022-10-10 09:08:25

一、CountDownLatch概述

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

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

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

  • 代码

    importjava.util.concurrent.CountDownLatch;/**
     * @description:  模拟员工下班关门案例
     * @author: xz
     */publicclassCountDownLatchDemo1{publicstaticvoidmain(String[] args)throwsInterruptedException{closeDoor();}privatestaticvoidcloseDoor()throwsInterruptedException{//创建CountDownLatch,初始容量为10,模拟10名员工CountDownLatch countDownLatch=newCountDownLatch(10);for(int i=1;i<=10;i++){newThread(()->{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代码示例(使用枚举方式模拟员工下班关门案例)

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

  • 代码

    importlombok.Getter;/**
     * @description: 枚举类,定义10名员工
     * @author: xz
     * */publicenumEmpEnum{ONE(1,"刘一"),TWO(2,"陈二"),THREE(3,"张三"),FOUR(4,"李四"),FIVE(5,"王五"),SIX(6,"赵六"),SEVEN(7,"孙七"),EIGHT(8,"周八"),NINE(9,"吴九"),TEN(10,"郑十");@Getterprivateint code;//员工编号@GetterprivateString name;//员工名称EmpEnum(Integer code,String name){this.code= code;this.name= name;}publicstaticEmpEnumforEach(int index){EmpEnum[]EmpEnums=EmpEnum.values();for(EmpEnum epmEnum:EmpEnums){if(index== epmEnum.getCode()){return epmEnum;}}returnnull;}}
    publicclassCountDownLatchDemo2{publicstaticvoidmain(String[] args)throwsInterruptedException{closeDoor();}privatestaticvoidcloseDoor()throwsInterruptedException{//创建CountDownLatch,初始容量为10,模拟10名员工CountDownLatch countDownLatch=newCountDownLatch(10);for(int i=1;i<=10;i++){newThread(()->{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值班人员锁门离开公司");}}
  • 输出结果如下图:
    在这里插入图片描述

  • 作者:小志的博客
  • 原文链接:https://wwwxz.blog.csdn.net/article/details/122353217
    更新时间:2022-10-10 09:08:25