Java并发多线程编程之CountDownLatch的用法
作者：小志的博客
这篇文章主要介绍了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值班人员锁门离开公司");
}
}输出结果如下图：
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。