前段时间在做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();
}
}
}