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