前段时间在做java多线程,然后涉及到了一个效率的问题。
java多线程中,所有线程执行完毕,总共使用多少时间呢?
import java.util.concurrent.CountDownLatch;
countDwonlatch提供了最常用的一些测试方法。
创建一个countDownLatch对象:
CountDownLatch countDownLatch = new CountDownLatch(500); //这个构造函数的入参为 int num,表示当前线程的总数,这500就表示有500个线程
countDownLatch.countDown(); //这个方法执行 会使总线程数-1,比如上面总线程为500,执行这个方法后为499,然后直到数量为0时,主线程从挂起状态恢复。
countDownLatch.await(); //将主线程挂起等待,知道countDown()将总数量变成0时,恢复主线程。
这里要注意的是,countDownLatch.await();会导致程序直接挂起,后面代码不再执行,所有如果你countDown()无效时,可能你提前await()该线程。
正确的使用方式是,要全部的(充分的)执行完countDwon();后在紧跟await();
下面列出代码:
public class threadTimtCount implements Runnable { static long startTime = System.currentTimeMillis();// 开始时间 final static CountDownLatch countDownLatch = new CountDownLatch(500); public static void main(String[] args) throws InterruptedException { threadTimtCount count = new threadTimtCount(); for (int i = 1; i <= 500; i++) { Thread thread = new Thread(count); thread.start();
//countDownLatch.await(); 错误的写法,这会导致thread执行一遍之后,线程被挂起,然后第二次for循环无法执行了(程序挂起等待),这样造成程序假死(卡死) } countDownLatch.await(); //一定要等到countDown()方法执行完毕后才使用 System.out.println("执行总时间:"+(System.currentTimeMillis()-startTime)); } @Override public void run() { try { Thread.sleep(timeIndex); System.out.println("currThread " + Thread.currentThread().getName()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ countDownLatch.countDown(); } } }