首页 > 代码库 > Java多线程--让主线程等待所有子线程执行完毕

Java多线程--让主线程等待所有子线程执行完毕

主要方法

 public CountDownLatch(int count);

 public void countDown();

 public void await() throws InterruptedException
 

构造方法参数指定了计数的次数

countDown方法,当前线程调用此方法,则计数减一

awaint方法,调用此方法会一直阻塞当前线程,直到计时器的值为0

 

例子

Java代码 <EMBED type=application/x-shockwave-flash pluginspage=http://www.macromedia.com/go/getflashplayer height=15 width=14 src=http://www.iteye.com/javascripts/syntaxhighlighter/clipboard_new.swf allowscriptaccess="always" quality="high" flashvars="clipboard=public%20class%20CountDownLatchDemo%20%7B%0A%09final%20static%20SimpleDateFormat%20sdf%3Dnew%20SimpleDateFormat(%22yyyy-MM-dd%20HH%3Amm%3Ass%22)%3B%0A%20%20%20%20public%20static%20void%20main(String%5B%5D%20args)%20throws%20InterruptedException%20%7B%0A%20%20%20%20%09CountDownLatch%20latch%3Dnew%20CountDownLatch(2)%3B%2F%2F%E4%B8%A4%E4%B8%AA%E5%B7%A5%E4%BA%BA%E7%9A%84%E5%8D%8F%E4%BD%9C%0A%20%20%20%20%09Worker%20worker1%3Dnew%20Worker(%22zhang%20san%22%2C%205000%2C%20latch)%3B%0A%20%20%20%20%09Worker%20worker2%3Dnew%20Worker(%22li%20si%22%2C%208000%2C%20latch)%3B%0A%20%20%20%20%09worker1.start()%3B%2F%2F%0A%20%20%20%20%09worker2.start()%3B%2F%2F%0A%20%20%20%20%09latch.await()%3B%2F%2F%E7%AD%89%E5%BE%85%E6%89%80%E6%9C%89%E5%B7%A5%E4%BA%BA%E5%AE%8C%E6%88%90%E5%B7%A5%E4%BD%9C%0A%20%20%20%20%20%20%20%20System.out.println(%22all%20work%20done%20at%20%22%2Bsdf.format(new%20Date()))%3B%0A%09%7D%0A%20%20%20%20%0A%20%20%20%20%0A%20%20%20%20static%20class%20Worker%20extends%20Thread%7B%0A%20%20%20%20%09String%20workerName%3B%20%0A%20%20%20%20%09int%20workTime%3B%0A%20%20%20%20%09CountDownLatch%20latch%3B%0A%20%20%20%20%09public%20Worker(String%20workerName%20%2Cint%20workTime%20%2CCountDownLatch%20latch)%7B%0A%20%20%20%20%09%09%20this.workerName%3DworkerName%3B%0A%20%20%20%20%09%09%20this.workTime%3DworkTime%3B%0A%20%20%20%20%09%09%20this.latch%3Dlatch%3B%0A%20%20%20%20%09%7D%0A%20%20%20%20%09public%20void%20run()%7B%0A%20%20%20%20%09%09System.out.println(%22Worker%20%22%2BworkerName%2B%22%20do%20work%20begin%20at%20%22%2Bsdf.format(new%20Date()))%3B%0A%20%20%20%20%09%09doWork()%3B%2F%2F%E5%B7%A5%E4%BD%9C%E4%BA%86%0A%20%20%20%20%09%09System.out.println(%22Worker%20%22%2BworkerName%2B%22%20do%20work%20complete%20at%20%22%2Bsdf.format(new%20Date()))%3B%0A%20%20%20%20%09%09latch.countDown()%3B%2F%2F%E5%B7%A5%E4%BA%BA%E5%AE%8C%E6%88%90%E5%B7%A5%E4%BD%9C%EF%BC%8C%E8%AE%A1%E6%95%B0%E5%99%A8%E5%87%8F%E4%B8%80%0A%0A%20%20%20%20%09%7D%0A%20%20%20%20%09%0A%20%20%20%20%09private%20void%20doWork()%7B%0A%20%20%20%20%09%09try%20%7B%0A%09%09%09%09Thread.sleep(workTime)%3B%0A%09%09%09%7D%20catch%20(InterruptedException%20e)%20%7B%0A%09%09%09%09e.printStackTrace()%3B%0A%09%09%09%7D%0A%20%20%20%20%09%7D%0A%20%20%20%20%7D%0A%20%20%20%20%0A%20%20%20%20%20%0A%7D%0A" wmode="transparent"> 收藏代码

  1. public class CountDownLatchDemo {  

  2.     final static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  

  3.     public static void main(String[] args) throws InterruptedException {  

  4.         CountDownLatch latch=new CountDownLatch(2);//两个工人的协作  

  5.         Worker worker1=new Worker("zhang san"5000, latch);  

  6.         Worker worker2=new Worker("li si"8000, latch);  

  7.         worker1.start();//  

  8.         worker2.start();//  

  9.         latch.await();//等待所有工人完成工作  

  10.         System.out.println("all work done at "+sdf.format(new Date()));  

  11.     }  

  12.       

  13.       

  14.     static class Worker extends Thread{  

  15.         String workerName;   

  16.         int workTime;  

  17.         CountDownLatch latch;  

  18.         public Worker(String workerName ,int workTime ,CountDownLatch latch){  

  19.              this.workerName=workerName;  

  20.              this.workTime=workTime;  

  21.              this.latch=latch;  

  22.         }  

  23.         public void run(){  

  24.             System.out.println("Worker "+workerName+" do work begin at "+sdf.format(new Date()));  

  25.             doWork();//工作了  

  26.             System.out.println("Worker "+workerName+" do work complete at "+sdf.format(new Date()));  

  27.             latch.countDown();//工人完成工作,计数器减一  

  28.   

  29.         }  

  30.           

  31.         private void doWork(){  

  32.             try {  

  33.                 Thread.sleep(workTime);  

  34.             } catch (InterruptedException e) {  

  35.                 e.printStackTrace();  

  36.             }  

  37.         }  

  38.     }  

  39.       

  40.        

  41. }  

 

输出:

Worker zhang san do work begin at 2011-04-14 11:05:11
Worker li si do work begin at 2011-04-14 11:05:11
Worker zhang san do work complete at 2011-04-14 11:05:16
Worker li si do work complete at 2011-04-14 11:05:19
all work done at 2011-04-14 11:05:19


Java多线程--让主线程等待所有子线程执行完毕