多线程任务协作:CountDownLatch的使用
多线程任务协作中,如果有一个任务,需要在其他线程的任务完成以后才能执行的情况下,CountDownLatch就派上用场,它能使用很少的代码,省掉一堆wait和notify,帮你很放心的完成这种协作。
使用步骤:
1. 首先所有协作线程都引用同一个CountDownLatch
2. CountDownLatch初始化传入一个计数器
3. 最后执行的那个任务,需要调用CountDownLatch.await方法
4. 当CountDownLatch的计数器数值为0的时候,await的那个任务就能自动执行
5. 前面的多个任务,需要调用CountDownLatch.countDown来减少计数器的数目
public static void testCountDown(){ int size=10; final CountDownLatch latch=new CountDownLatch(size); final Random r=new Random(47); ExecutorService se=Executors.newCachedThreadPool(); for(int i=0;i<size+10;i++){ se.execute(new Runnable(){ public void run() { try { TimeUnit.MILLISECONDS.sleep(r.nextInt(10)*1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("Preinitial--"); latch.countDown(); } }); } se.execute(new Runnable(){ public void run() { try { latch.await(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("Ready go!"); }} ); } public static void main(String args[]){ testCountDown(); }