Java 中建立一個執行緒往往意味著JVM 會建立相應依賴於宿主機作業系統的本地執行緒（Native Thread)。

Thread Pool 模式的本質是使用極其有限的資源去處理相對無限的任務。核心思想是使用佇列對待處理的任務進行快取，並複用一定數量的工作者執行緒去取佇列中的任務進行執行。
工作佇列通常可以在有界佇列（Bounded Queue)、無界佇列（Unbound Queue) 和直接交接佇列（SynchronousQueue) 之間選擇。因此，無界工作佇列可能會導致系統的不穩定性，適合在任務佔用的記憶體空間以及其他稀缺資源比較少的情況下使用。

9.4.2 執行緒池大小的調校

任務的特性主要考慮任務是CPU 密集型、I/O密集型,還是混合型。

1. 對於CPU 密集型任務，相應的執行緒池的大小可以考慮設定為 Ncpu+1$N_{cpu}+1$。+1 考慮到即便是CPU 密集型的任務，其執行執行緒也可能在某一個時刻（如因為缺頁中斷），而出現等待。

2. 對於I/O 密集型任務，我們需要注意I/O 操作會引起上下文切換。
   在作業系統中，CPU切換到另一個程序需要儲存當前程序的狀態並恢復另一個程序的狀態：當前執行任務轉為就緒（或者掛起、刪除）狀態，另一個被選定的就緒任務成為當前任務。上下文切換包括儲存當前任務的執行環境，恢復將要執行任務的執行環境。
   程序上下文用程序的PCB（程序控制塊,也稱為PCB，即任務控制塊）表示，它包括程序狀態，CPU暫存器的值等。
   不妨將相應的執行緒池大小設為

   2∗Ncpu$2\ast N_{cpu}$

    public static void main(String[] args){
   
   ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, Runtime.getRuntime().availableProcessors()*2, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(200));
   
   threadPool.submit(new IOIntensiveTask());
   
   }
   
      private static class IOIntensiveTask implements Runnable{
   
   public void run() {
       System.out.println("lele");
   }
   }
    
   

3. 對於混合型，可以考慮將其拆分成CPU密集型和I/O密集型 的子任務。
   一個計算執行緒合理大小的公式，為：
   S+Ncpu∗Ucpu∗(1+WTST)$S+N_{cpu}\ast U_{cpu}\ast (1+\frac{WT}{ST})$
   S$S$ 為執行緒池合理大小，Ncpu$N_{cpu}$ 為CPU 個數，Ucpu$U_{cpu}$ 為目標CPU 使用率，WT$WT$ 為任務執行執行緒進行等待的時間， ST$ST$ 為任務執行執行緒使用CPU 進行計算的時間。ST、WT$ST、WT$ 可以藉助工具（如 jvisualvm)計算出相應值。

9.4.3 執行緒池監控

9.4.4 執行緒洩漏

9.4.5 可靠性與執行緒池飽和處理策略

9.4.6 防止死鎖

public class ThreadPoolDeadLockAvoidance {

private final ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS, new SynchronousQueue<Runnable>(), new ThreadPoolExecutor.CallerRunsPolicy());

public static void main(String[] args){
    ThreadPoolDeadLockAvoidance me = new ThreadPoolDeadLockAvoidance();
    me.test("This will not deadlock");
}

public void test(final String message){
    Runnable taskA = new Runnable() {
        public void run() {
            System.out.println("Executing TaskA ...");
            Runnable taskB = new Runnable() {
                public void run() {
                    System.out.println("TaskB processes "+ message);
                }
            };
            Future<?> result = threadPool.submit(taskB);

            try{
                result.get();
            }catch (InterruptedException e){
                ;
            }catch (ExecutionException e){
                e.printStackTrace();
            }

            System.out.println("Task A Done.");
        }
    };

    threadPool.submit(taskA);

}
}