Windows 服務開發深度解析 (四)：高階疑難雜症——線程通信、狀態回報策略與優雅停止

前言：從「能跑」到「好用、穩、可維護」

前三篇涵蓋了服務啟動、調度、控制處理的標準流程。但實際工程中，複雜業務 (高併發網絡、長事務、多線程池) 會暴露核心難題：

1. CtrlHandler 線程與 ServiceMain 工作線程如何安全協作？ (停止、暫停、配置熱更)
2. 何時、如何調用 SetServiceStatus 才不會被 SCM 誤殺或卡死？
3. 為什麼 TerminateThread 是大忌？優雅停止的正確姿勢是什麼？

本文基於實戰踩坑經驗，給出工業級解決方案。

核心難題一：跨線程控制命令傳遞

錯誤示範：暴力 TerminateThread

// CtrlHandler 中 ❌
case SERVICE_CONTROL_STOP:
    TerminateThread(g_hWorkerThread, 0); // 災難！資源洩漏、鎖死、DLL 無通知、數據損壞
    break;

後果：目標線程無執行 `finally`/`__finally`、析構函數、SEH 解鎖、關閉句柄、釋放鎖、刷新緩衝區的機會 → **死鎖、內存洩漏、數據庫損壞、句柄耗盡**。

正確模型：信號 + 狀態機 + 線程安全通信

**原則**：CtrlHandler 只負責 **「狀態回報」+「發送停止信號」**，工作線程 **主動輪詢/等待信號** 並 **自主清理退出**。

方案對比與選型指南

最佳實踐：事件對象 + 原子狀態機 (通用模板)

// 全局/類成員
HANDLE g_hStopEvent = CreateEvent(NULL, TRUE, FALSE, NULL); // 手動重置，初始非觸發
HANDLE g_hPauseEvent = CreateEvent(NULL, TRUE, TRUE, NULL); // 初始觸發 (運行狀態)
std::atomic g_serviceState = SERVICE_RUNNING; // 當前邏輯狀態

// CtrlHandler
VOID WINAPI CtrlHandler(DWORD dwCtrl) {
    switch (dwCtrl) {
        case SERVICE_CONTROL_STOP:
            // 1. 立即回報 PENDING
            ReportStatus(SERVICE_STOP_PENDING, 1, 30000);
            // 2. 發信號通知所有工作線程
            InterlockedExchange(&g_serviceState, SERVICE_STOP_PENDING);
            SetEvent(g_hStopEvent); // 廣播停止
            // 3. 可選：喚醒可能阻塞在 IO 的線程 (CancelIoEx, closesocket, shutdown)
            break;
        case SERVICE_CONTROL_PAUSE:
            ReportStatus(SERVICE_PAUSE_PENDING, 1, 10000);
            InterlockedExchange(&g_serviceState, SERVICE_PAUSE_PENDING);
            ResetEvent(g_hPauseEvent); // 讓線程在 WaitForSingleObject(g_hPauseEvent) 處阻塞
            break;
        case SERVICE_CONTROL_CONTINUE:
            ReportStatus(SERVICE_CONTINUE_PENDING, 1, 5000);
            InterlockedExchange(&g_serviceState, SERVICE_CONTINUE_PENDING);
            SetEvent(g_hPauseEvent); // 釋放繼續
            break;
    }
}

// 工作線程主迴路
DWORD WINAPI WorkerThread(LPVOID) {
    while (true) {
        // 1. 檢查停止信號 (零開銷原子讀取)
        if (g_serviceState == SERVICE_STOP_PENDING || WaitForSingleObject(g_hStopEvent, 0) == WAIT_OBJECT_0) {
            break; // 跳出迴路進入清理階段
        }
        // 2. 暫停支持：等待繼續事件 (不消耗 CPU)
        WaitForSingleObject(g_hPauseEvent, INFINITE);
        if (g_serviceState == SERVICE_STOP_PENDING) break; // 暫停期間收到停止
        
        // 3. 執行核心業務邏輯 (處理請求、計算、IO...)
        DoWorkCycle();
    }
    
    // 4. 優雅清理階段 (無超時壓力，但盡快)
    CleanupResources(); // 關閉 Socket、提交事務、釋放鎖、Flush 緩衝
    
    // 5. 最後由主線程 (或最後一個工作線程) 回報 STOPPED
    // 通常在 ServiceMain 等待所有工作線程結束後統一回報
    return 0;
}

// ServiceMain 協調
VOID WINAPI ServiceMain(...) {
    // ... 初始化 ...
    ReportStatus(SERVICE_RUNNING, 0, 0);
    
    // 創建工作線程池
    std::vector threads;
    for (int i=0; i

g_status.dwWin32ExitCode = NO_ERROR;           // 正常退出
// 異常退出時：
g_status.dwWin32ExitCode = ERROR_SERVICE_SPECIFIC_ERROR; // 0x424
g_status.dwServiceSpecificExitCode = MY_INTERNAL_ERROR_DB_CONN_FAILED; // 自定義碼