CountDownLatch:倒计数器
CountDownLatch作用:
是一个非常实用的JDK多线程工具类,是一个用来计算线程数量的倒计数器。它能起到线程之间通信的作用,能够使一个线程在等待另外一些线程完成各自工作之后,再继续执行
简单的理解:
有这样一种场景,main主方法(主线程)内用多个线程执行一个打印1-10的任务,必须等所有线程执行完该任务以后,主线程才能继续往下执行其它逻辑。
CountDownLatch的不足
它是一次性的,计算器的值只能在构造方法中初始化一次,之后没有任何机制再次对其设置值,不能被再此使用;
CountDownLatch构造函数:
public CountDownLatch(int count):其中的count就是当前要倒计数的计数个数;
简单示例:
package com.demo.spring.test.baseThread;import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;/*** CountDownLatch:倒计时器*/
public class CountDownLatchDemo implements Runnable{
// 初始化倒计数器:10个线程static final CountDownLatch latch = new CountDownLatch(10);// 使用线程安全的AtomicInteger来输出1-10static final AtomicInteger integer = new AtomicInteger();@Overridepublic void run() {
// 输出线程的名称和数值:方便查看结果执行情况:System.out.println(Thread.currentThread().getName()+":"+integer.getAndIncrement());// 模拟业务执行耗时try {
Thread.sleep(new Random().nextInt(2000));} catch (InterruptedException e) {
e.printStackTrace();}latch.countDown();}public static void main(String[] args) {
// 创建线程池,有4个执行线程ExecutorService pool = Executors.newFixedThreadPool(4);CountDownLatchDemo demo = new CountDownLatchDemo();for(int i = 0;i<10;i++){
pool.submit(demo);}try {
latch.await();} catch (InterruptedException e) {
e.printStackTrace();}finally {
// 记得关闭线程池pool.shutdown();}System.out.println("打印线程任务完成----");System.out.println("主线程任务继续完成执行---");}
}
执行结果:
pool-1-thread-2:1
pool-1-thread-1:2
pool-1-thread-3:3
pool-1-thread-4:4
pool-1-thread-1:5
pool-1-thread-1:6
pool-1-thread-1:7
pool-1-thread-1:8
pool-1-thread-2:9
pool-1-thread-3:10
打印线程任务完成----
主线程任务继续完成执行---
从执行结果不难看出:线程池1中的4个线程轮流完成了1-10的输出工作,且在1-10的任务完成以后主线程才继续往下执行其它任务代码;