/**
 * 多任務(wù)并行統(tǒng)計(jì)
 * 創(chuàng)建者 科幫網(wǎng)
 * 創(chuàng)建時(shí)間  2018年4月16日
 */
public class StatsDemo {
  final static SimpleDateFormat sdf = new SimpleDateFormat(
      "yyyy-MM-dd HH:mm:ss");
  
  final static String startTime = sdf.format(new Date());

  public static void main(String[] args) throws InterruptedException {
    CountDownLatch latch = new CountDownLatch(5);// 兩個(gè)賽跑者
    Stats stats1 = new Stats("任務(wù)A", 1000, latch);
    Stats stats2 = new Stats("任務(wù)B", 2000, latch);
    Stats stats3 = new Stats("任務(wù)C", 2000, latch);
    Stats stats4 = new Stats("任務(wù)D", 2000, latch);
    Stats stats5 = new Stats("任務(wù)E", 2000, latch);
    stats1.start();//任務(wù)A開(kāi)始執(zhí)行
    stats2.start();//任務(wù)B開(kāi)始執(zhí)行
    stats3.start();//任務(wù)C開(kāi)始執(zhí)行
    stats4.start();//任務(wù)D開(kāi)始執(zhí)行
    stats5.start();//任務(wù)E開(kāi)始執(zhí)行
    latch.await();// 等待所有人任務(wù)結(jié)束
    System.out.println("所有的統(tǒng)計(jì)任務(wù)執(zhí)行完成:" + sdf.format(new Date()));
  }

  static class Stats extends Thread {
    String statsName;
    int runTime;
    CountDownLatch latch;

    public Stats(String statsName, int runTime, CountDownLatch latch) {
      this.statsName = statsName;
      this.runTime = runTime;
      this.latch = latch;
    }

    public void run() {
      try {
        System.out.println(statsName+ " do stats begin at "+ startTime);
        //模擬任務(wù)執(zhí)行時(shí)間
        Thread.sleep(runTime);
        System.out.println(statsName + " do stats complete at "+ sdf.format(new Date()));
        latch.countDown();//單次任務(wù)結(jié)束，計(jì)數(shù)器減一
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
}