Java统计多线程执行完毕后的总耗时(CountDownLatch)

---

前言

关于计算多线程并发执行的总耗时，可以使用CountDownLatch类的await()方法和countDown()方法来实现

---

一、CountDownLatch是什么？

CountDownLatch简称：闭锁、倒计时锁

主要使用的是两个方法：await()、countDown()

await()：会阻塞所有调用了该方法的线程，当CountDownLatch的计数器为0时才放行

countDown()：会使CountDownLatch的计数器减1

二、统计所有线程执行完毕的总耗时（代码）

import java.util.concurrent.CountDownLatch;

/**
 * @author 弹弹霹雳
 * @create 2020-11-22-17:08
 */
public class TestCountDownLatch {
    public static void main(String[] args) throws InterruptedException {
    	//创建一个CountDownLatch对象，并调用构造器将计数器设置为5
        CountDownLatch latch = new CountDownLatch(5);
        //创建一个LatchDemo对象，并将CountDownLatch的实例对象传入
        LatchDemo ld = new LatchDemo(latch);
		//记录开始时间
        long start = System.currentTimeMillis();
		//通过循环创建并启动五个线程
        for(int i = 0; i < 5; i++){
            new Thread(ld).start();
        }
        try {
        	//调用await()方法，阻塞主线程，当上述启动的5个分线程都执行完后，主线程才会被放行
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //记录下结束时间
        long end = System.currentTimeMillis();
        System.out.println("消耗的时间为（毫秒）：" + (end - start));
    }
}

class LatchDemo implements Runnable{
	//用来存放一个闭锁
    private CountDownLatch latch;
    //构造器初始化
    public LatchDemo(CountDownLatch latch){
        this.latch = latch;
    }
    @Override
    public void run() {
        try{
        	//每个线程都会打印出0 ~ 9999
            for(int i = 0; i < 10000; i++){
                System.out.println(Thread.currentThread().getName() + " : " + i);
            }
        }finally {
        	//将该代码放入finally中，确保这段代码一定能执行，否则主线程无法结束
            latch.countDown();	//让CountDownLatch计数器减1
        }

    }
}

本文地址：https://blog.csdn.net/weixin_48029654/article/details/109958550