# 線程池入門到精通 ## 什么是線程池 * 復用創建好的線程，節約創建和銷毀的時間。 * 需要使用線程時，就從池子里拿一個空閑的線程，完成工作后，歸還線程給線程池。 ## 線程池工作原理  ## 線程池工作流程  ## 線程池生命周期及擴展點  ## 線程池參數  ## JDK提供的線程池  ## 線程池常見阻塞隊列  ## 線程池內置拒絕策略  ## 線程池核心線程數設置  ## Fork/Join框架 ### 執行邏輯  ### 竊取原理  ### 任務類圖  ### 例子 求開始數到結束數的和。 ~~~ package org.mango.demo.mt.thread; import java.util.ArrayList; import java.util.List; import java.util.concurrent.*; /** * 遞歸任務，帶返回值的 * @Author: mango * @Date: 2022/6/27 10:18 下午 */ public class SumTask extends RecursiveTask<Long> implements Callable<Long> { // 臨界值 private static final int THRESHOLD = 10000; private long start; private long end; public SumTask(long start,long end){ this.start = start; this.end = end; } @Override protected Long compute() { long sum = 0L; boolean canSum = (end-start) < THRESHOLD; if(canSum){ for(long i=start;i<=end;i++){ sum += i; } }else{ // 分成100個小任務 int count = 100; long step = (end-start)/count; List<SumTask> sumTasks = new ArrayList<>(); // 游標 long cursor = start; for(int i=0;i<count;i++){ long theEnd = cursor + step; if(theEnd > end){ theEnd = end; } SumTask sumTask = new SumTask(cursor,theEnd); // 游標下移動 cursor += step + 1; // 將任務加入集合，并開啟子任務 sumTasks.add(sumTask); sumTask.fork(); } // 合并子任務結果 for (SumTask sumTask : sumTasks){ sum += sumTask.join(); } } return sum; } public static void main(String[] args) throws ExecutionException, InterruptedException { ForkJoinPool forkJoinPool = new ForkJoinPool(); SumTask sumTask = new SumTask(1,123456789L); Long result = forkJoinPool.invoke(sumTask); System.out.println("結果為:"+result); // ForkJoinTask<Long> forkJoinTask = forkJoinPool.submit(sumTask); // try { // Long result2 = forkJoinTask.get(); // } catch (InterruptedException e) { // e.printStackTrace(); // } catch (ExecutionException e) { // e.printStackTrace(); // } ExecutorService executorService = Executors.newWorkStealingPool(); Future<Long> t = executorService.submit(sumTask); Long result2 = t.get(); System.out.println(result2); } @Override public Long call() throws Exception { return compute(); } } ~~~ ## 參考文檔 * https://www.zhihu.com/question/41134816 * 書籍：葛一鳴 *《Java高并發程序設計第二版》