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

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

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

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

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

 // 關(guān)閉線程的原理
 // a. 遍歷線程池中的所有工作線程
 // b. 逐個(gè)調(diào)用線程的interrupt（）中斷線程（注：無(wú)法響應(yīng)中斷的任務(wù)可能永遠(yuǎn)無(wú)法終止）

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

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

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

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

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

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

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

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

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

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

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

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

//當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成
//那么會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程，而不用每次新建線程。

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

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

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

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