伺服器程式大量使用線程處理請求已成常態，但「請求到來 → 建立線程 → 處理 → 銷毀線程」的傳統模式隱藏著巨大效能陷阱。線程池技術透過「複用線程、控制併發、分離生命週期」三大機制，成為高效能伺服器的標準配置。本文深入剖析線程池原理、手寫核心實現、並透過效能對比驗證優化效果。
完成一個任務的總耗時 T = T1(建立) + T2(執行) + T3(銷毀)。其中 T1、T3 純屬線程管理開銷，不產生業務價值。若頻繁建立/銷毀線程，T1+T3 佔比極高，反而拖慢響應。
JVM 內每個線程佔用約 1MB 棧空間。若同時處理 50,000 請求對應 50,000 線程，記憶體將耗盡，或導致 CPU 在上下文切換中耗盡時間片（Thrashing）。
T1、T3 分攤到海量任務上一個最小可用線程池包含四大組件：
| 組件 | 職責 | 關鍵資料結構 |
|---|---|---|
| ThreadPoolManager | 池的建立、銷毀、監控、任務提交入口 | 工作線程集合、任務隊列引用 |
| WorkThread | 實際執行任務的線程，循環從隊列取任務 | 執行緒狀態、所屬池引用 |
| Task Interface | 任務契約，定義 execute() 方法 | 業務參數、回調介面 |
| Task Queue | 緩衝待執行任務，解耦提交與執行 | BlockingQueue 實現（ArrayBlockingQueue/LinkedBlockingQueue） |
public interface Task {
void execute(); // 業務邏輯入口
}
public class WorkThread extends Thread {
private final BlockingQueue taskQueue;
private volatile boolean shutdown = false;
public WorkThread(BlockingQueue queue) {
this.taskQueue = queue;
}
@Override
public void run() {
while (!shutdown || !taskQueue.isEmpty()) {
try {
Task task = taskQueue.poll(1, TimeUnit.SECONDS);
if (task != null) {
task.execute(); // 執行業務邏輯
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
} catch (Exception e) {
// 記錄異常，防止線程意外死亡
logger.error("Task execution failed", e);
}
}
}
public void shutdown() { this.shutdown = true; }
}
public class SimpleThreadPool {
private final List workers = new ArrayList<>();
private final BlockingQueue taskQueue;
private final int poolSize;
public SimpleThreadPool(int poolSize, int queueCapacity) {
this.poolSize = poolSize;
this.taskQueue = new LinkedBlockingQueue<>(queueCapacity);
initialize();
}
private void initialize() {
for (int i = 0; i < poolSize; i++) {
WorkThread worker = new WorkThread(taskQueue);
worker.start();
workers.add(worker);
}
}
public void submit(Task task) throws InterruptedException {
taskQueue.put(task); // 隊列滿時阻塞，實現背壓
}
public void shutdown() {
workers.forEach(WorkThread::shutdown);
workers.forEach(t -> {
try { t.join(); } catch (InterruptedException ignored) {}
});
}
}
測試場景：模擬 50,000 個短任務（耗時 1ms），對比「每請求一線程」vs「固定 50 線程池」。
| 指標 | 每請求一線程 | 線程池 (50線程) | 提升 |
|---|---|---|---|
| 總建立線程數 | 50,000 | 50 | 1000x 減少 |
| 平均響應時間 | ~15ms (含建立銷毀) | ~1.2ms | 12x 更快 |
| 記憶體峰值 | ~2GB+ (易 OOM) | ~100MB | 穩定可控 |
| CPU 上下文切換 | 極高 (Thrashing) | 低且穩定 | 系統穩定 |
ArrayBlockingQueue 公平性較好CallerRunsPolicy 由提交者執行（自然限流）、AbortPolicy 拋異常order-processor-%d）、設為守護線程、配置 UncaughtExceptionHandlerallowCoreThreadTimeOut(true) 讓核心線程也可回收CompletableFuture 非同步編排execute() 內捕獲所有異常並記錄，否則線程悄悄死亡導致池縮水shutdown() → awaitTermination() → shutdownNow() 三步走線程池不是銀彈，但它是高併發伺服器的基石。理解「複用、隔離、控制」三大原理，掌握核心參數調優，並警惕 ThreadLocal 洩漏、異常吞沒等坑點，才能駕馭線程池發揮最大效能。生產環境建議直接使用 ThreadPoolExecutor 或成熟框架（HikariCP、Tomcat、Netty 內建池），站在巨人肩膀上構建穩健系統。
