package com.yao;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * CountDownLatch是個(gè)計(jì)數(shù)器，它有一個(gè)初始數(shù)，
 * 等待這個(gè)計(jì)數(shù)器的線程必須等到計(jì)數(shù)器倒數(shù)到零時(shí)才可繼續(xù)。
 */
public class CountDownLatchTest {

 /**
  * 初始化組件的線程
  */
 public static class ComponentThread implements Runnable {
  // 計(jì)數(shù)器
  CountDownLatch latch;
  // 組件ID
  int ID;

  // 構(gòu)造方法
  public ComponentThread(CountDownLatch latch, int ID) {
   this.latch = latch;
   this.ID = ID;
  }

  public void run() {
   // 初始化組件
   System.out.println("Initializing component " + ID);
   try {
    Thread.sleep(500 * ID);
   } catch (InterruptedException e) {
   }
   System.out.println("Component " + ID + " initialized!");
   //將計(jì)數(shù)器減一
   latch.countDown();
  }
 }

 /**
  * 啟動(dòng)服務(wù)器
  */
 public static void startServer() throws Exception {
  System.out.println("Server is starting.");
  //初始化一個(gè)初始值為3的CountDownLatch
  CountDownLatch latch = new CountDownLatch(3);
  //起3個(gè)線程分別去啟動(dòng)3個(gè)組件
  ExecutorService service = Executors.newCachedThreadPool();
  service.submit(new ComponentThread(latch, 1));
  service.submit(new ComponentThread(latch, 2));
  service.submit(new ComponentThread(latch, 3));
  service.shutdown();

  //等待3個(gè)組件的初始化工作都完成
  latch.await();

  //當(dāng)所需的三個(gè)組件都完成時(shí)，Server就可繼續(xù)了
  System.out.println("Server is up!");
 }

 public static void main(String[] args) throws Exception {
  CountDownLatchTest.startServer();
 }
}