您现在的位置：程式碼之家 >> 編程語言 > >> C語言 >> C++ >> 關於C++

C++ 可擴展線程池設計與實現：任務物件、執行緒策略、效能調優完整指南

編輯：關於C++

前言

高併發伺服器中，頻繁建立/銷毀執行緒開銷巨大。線程池預先建立執行緒、複用處理任務，能大幅提升吞吐量。本文詳細闡述通用線程池的架構設計：任務物件抽象、執行緒動態伸縮策略、任務分配機制、異常安全，並附偽代碼流程與效能測試分析。

一、核心設計三大支柱

維度	核心問題	解決方案
任務物件通用性	業務邏輯千差萬別	純虛函數 `run()` 介面，衍生類別實作具體邏輯
執行緒創建/銷毀策略	何時增減執行緒	初始 N1、擴容 N3、閒置超時銷毀 N4，保留基線 N1
任務分配策略	輕量任務分配開銷大	批次派發：單執行緒連續處理 N5 個任務

二、任務物件抽象


class Task {
public:
    Task();
    virtual ~Task();
    virtual bool run() = 0;  // 返回 true=任務完成銷毀, false=繼續執行
};

建立時機：需要時 new 動態建立，傳入線程池
完成判定：由任務自身 run() 返回值決定
資源管理：建構函數獲取資源，解構函數釋放，run() 實作邏輯

三、執行緒池動態調整模型

參數定義

N1 = 初始執行緒數 = N2 × n1 (N2 = 平均單次業務任務數)
N3 = 擴容數量 = N2 × n2 (全忙時)
N4 = 縮容數量 = N2 × n3 (閒置超時)
T = 閒置超時閾值
THREAD_MAX = 硬性上限

調整邏輯

啟動時建立 N1 個執行緒放入閒置隊列
任務到達 → 取閒置執行緒 → 派發任務
無閒置且未達上限 → 建立 N3 個新執行緒
執行緒任務完成 → 回閒置隊列 → 計時
閒置超過 T → 銷毀 N4 個 (保留至少 N1)

四、任務批次派發優化

輕量任務 (如 5ms) 下，單次派發開銷佔比高。解決：單執行緒連續處理 N5 個任務。

N5 = 1：逐個派發
N5 > 1：批次派發，減少鎖競爭、上下文切換
測試證實：N5 = 5 時吞吐量近乎翻倍

五、核心流程偽代碼

1. 線程池主迴圈 (調度執行緒)


for (;;) {
    pThread = GetIdleThread();
    if (pThread) {
        if (CheckNewTask()) {
            TaskList tl;
            GetTask(tl, N5);  // 取 N5 個任務
            AddTaskToThread(pThread, tl);
            continue;
        }
    }
    if (!pThread && nThread < THREAD_MAX)
        CreateNewThread();
    
    // 無任務或達上限 → 等待
    if (WaitForTaskOrThreadTimeout()) {
        if (IncrIdleTime() > IDLE_MAX)
            DecrIdleThread();  // 縮容
    } else
        return 0;  // 關閉信號
}

2. 工作執行緒執行迴圈


for (;;) {
    if (!CheckTaskQueue()) {
        pPool->OnTaskIdle(this);  // 通知池：我閒置了
        if (WaitForTask()) continue;
        else return 0;  // 收到關閉信號
    }
    
    pTask = GetTask();
    try {
        while (!pTask->Run()) { /* 空迴圈，持續執行直到完成 */ }
    } catch (...) {
        WriteLog(...);  // 異常隔離，不讓單一任務摧毀服務
    }
    delete pTask;  // 任務完成，釋放
}