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

2022-07-27,,,,

文章目录

  • 前言
  • 一、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

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

下载本文的Word格式文档,以方便收藏与打印。