// 創(chuàng)建線程池對象如下
// 通過 構造方法 配置核心參數(shù)
  Executor executor = new ThreadPoolExecutor( 
                       CORE_POOL_SIZE,
                       MAXIMUM_POOL_SIZE,
                       KEEP_ALIVE,
                       TimeUnit.SECONDS, 
                       sPoolWorkQueue,
                       sThreadFactory 
                        );

// 構造函數(shù)源碼分析
  public ThreadPoolExecutor (int corePoolSize,
                int maximumPoolSize,
                long keepAliveTime,
                TimeUnit unit,
                BlockingQueue<Runnable workQueue>,
                ThreadFactory threadFactory )

// 1. 創(chuàng)建線程池
  // 創(chuàng)建時，通過配置線程池的參數(shù)，從而實現(xiàn)自己所需的線程池
  Executor threadPool = new ThreadPoolExecutor(
                       CORE_POOL_SIZE,
                       MAXIMUM_POOL_SIZE,
                       KEEP_ALIVE,
                       TimeUnit.SECONDS,
                       sPoolWorkQueue,
                       sThreadFactory
                       );
  // 注：在Java中，已內置4種常見線程池，下面會詳細說明

// 2. 向線程池提交任務：execute（）
  // 說明：傳入 Runnable對象
    threadPool.execute(new Runnable() {
      @Override
      public void run() {
        ... // 線程執(zhí)行任務
      }
    });

// 3. 關閉線程池shutdown() 
 threadPool.shutdown();

 // 關閉線程的原理
 // a. 遍歷線程池中的所有工作線程
 // b. 逐個調用線程的interrupt（）中斷線程（注：無法響應中斷的任務可能永遠無法終止）

 // 也可調用shutdownNow（）關閉線程：threadPool.shutdownNow（）
 // 二者區(qū)別：
 // shutdown：設置 線程池的狀態(tài) 為 SHUTDOWN，然后中斷所有沒有正在執(zhí)行任務的線程
 // shutdownNow：設置 線程池的狀態(tài) 為 STOP，然后嘗試停止所有的正在執(zhí)行或暫停任務的線程，并返回等待執(zhí)行任務的列表
 // 使用建議：一般調用shutdown（）關閉線程池；若任務不一定要執(zhí)行完，則調用shutdownNow（）

// 1. 創(chuàng)建定長線程池對象 & 設置線程池線程數(shù)量固定為3
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

// 2. 創(chuàng)建好Runnable類線程對象 & 需執(zhí)行的任務
Runnable task =new Runnable(){
 public void run(){
  System.out.println("執(zhí)行任務啦");
   }
  };

// 3. 向線程池提交任務：execute（）
fixedThreadPool.execute(task);

// 4. 關閉線程池
fixedThreadPool.shutdown();

// 1. 創(chuàng)建 定時線程池對象 & 設置線程池線程數(shù)量固定為5
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);

// 2. 創(chuàng)建好Runnable類線程對象 & 需執(zhí)行的任務
Runnable task =new Runnable(){
    public void run(){
       System.out.println("執(zhí)行任務啦");
     }
  };
// 3. 向線程池提交任務：schedule（）
scheduledThreadPool.schedule(task, 1, TimeUnit.SECONDS); // 延遲1s后執(zhí)行任務
scheduledThreadPool.scheduleAtFixedRate(task,10,1000,TimeUnit.MILLISECONDS);// 延遲10ms后、每隔1000ms執(zhí)行任務

// 4. 關閉線程池
scheduledThreadPool.shutdown();

// 1. 創(chuàng)建可緩存線程池對象
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// 2. 創(chuàng)建好Runnable類線程對象 & 需執(zhí)行的任務
Runnable task =new Runnable(){
 public void run(){
    System.out.println("執(zhí)行任務啦");
      }
  };

// 3. 向線程池提交任務：execute（）
cachedThreadPool.execute(task);

// 4. 關閉線程池
cachedThreadPool.shutdown();

//當執(zhí)行第二個任務時第一個任務已經完成
//那么會復用執(zhí)行第一個任務的線程，而不用每次新建線程。

// 1. 創(chuàng)建單線程化線程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

// 2. 創(chuàng)建好Runnable類線程對象 & 需執(zhí)行的任務
Runnable task =new Runnable(){
 public void run(){
    System.out.println("執(zhí)行任務啦");
      }
  };

// 3. 向線程池提交任務：execute（）
singleThreadExecutor.execute(task);

// 4. 關閉線程池
singleThreadExecutor.shutdown();