欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-04-03 15:58:25
关于计算多线程并发执行的总耗时,可以使用CountDownLatch类的await()方法和countDown()方法来实现...


前言

关于计算多线程并发执行的总耗时,可以使用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