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

/**
 * 測(cè)試監(jiān)控類
 * 
 * @author
 * 
 */
public class WatchThread {

 /**
 * 測(cè)試函數(shù)
 * 
 * @throws InterruptedException
 */
 public void testThread() throws InterruptedException {
 int threadNum = 10;
 // 初始化countDown
 CountDownLatch threadSignal = new CountDownLatch(threadNum);
 // 創(chuàng)建固定長(zhǎng)度的線程池
 Executor executor = Executors.newFixedThreadPool(threadNum);
 for (int i = 0; i < threadNum; i++) { // 開threadNum個(gè)線程
  Runnable task = new TestThread(threadSignal);
  // 執(zhí)行
  executor.execute(task);
 }
 threadSignal.await(); // 等待所有子線程執(zhí)行完
 // do work
 System.out.println(Thread.currentThread().getName() + "+++++++結(jié)束.");
 }

 /**
 * 測(cè)試函數(shù)
 */
 public static void main(String[] args) throws InterruptedException {
 WatchThread test = new WatchThread();
 test.testThread();
 }

 /**
 * 
 * @author jill
 * 
 */
 private class TestThread implements Runnable {
 private CountDownLatch threadsSignal;

 public TestThread(CountDownLatch threadsSignal) {
  this.threadsSignal = threadsSignal;
 }

 public void run() {
  System.out.println(Thread.currentThread().getName() + "開始...");
  // do shomething
  System.out.println("開始了線程：：：：" + threadsSignal.getCount());
  // 線程結(jié)束時(shí)計(jì)數(shù)器減1
  threadsSignal.countDown();  //這句代碼 建議放在 finally里執(zhí)行 
  System.out.println(Thread.currentThread().getName() + "結(jié)束. 還有"
   + threadsSignal.getCount() + " 個(gè)線程");
 }
 }

}