1. 項目概述為什么多線程同步是Windows桌面開發(fā)的“必修課”如果你在Windows平臺上用Visual CVC開發(fā)過稍微復(fù)雜一點的桌面應(yīng)用比如一個需要實時處理數(shù)據(jù)的監(jiān)控軟件、一個需要后臺下載同時保持界面響應(yīng)的工具或者一個需要同時控制多個硬件設(shè)備的程序那么你大概率已經(jīng)和“多線程”打過交道甚至可能被它搞得焦頭爛額。線程能讓你的程序“一心多用”充分利用多核CPU的性能但隨之而來的就是數(shù)據(jù)競爭、死鎖、界面卡頓等一系列讓人頭疼的問題。這時候“同步”和“事件”這兩個詞就不再是書本上的概念而是決定你程序能否穩(wěn)定運行的生死線。這個實戰(zhàn)工程就是聚焦于Visual C環(huán)境下如何運用Windows API提供的核心同步機(jī)制——特別是事件Event對象來構(gòu)建一個健壯、高效的多線程應(yīng)用。我們不會停留在CreateThread和Sleep的簡單演示而是深入到實際工程中常見的場景比如一個主線程通常是UI線程如何安全、高效地通知多個工作線程開始處理任務(wù)工作線程在處理完數(shù)據(jù)后又如何將結(jié)果“同步”回主線程更新界面而不引發(fā)崩潰這些問題的答案都藏在CreateEvent、SetEvent、WaitForSingleObject這些API的恰當(dāng)使用之中。對于開發(fā)者而言掌握這套機(jī)制意味著你能寫出響應(yīng)迅速、資源管理有序的C/MFC或Win32程序。無論是處理大量I/O操作、實現(xiàn)復(fù)雜的業(yè)務(wù)邏輯流水線還是構(gòu)建高性能的實時系統(tǒng)多線程同步都是繞不開的核心技能。接下來我們就從最根本的需求開始拆解一步步搭建一個可用的實戰(zhàn)框架。1.1 核心需求解析從“數(shù)據(jù)混亂”到“有序協(xié)作”在單線程程序中代碼順序執(zhí)行世界一片祥和。但一旦引入多線程共享數(shù)據(jù)就變成了一個“公共廁所”如果不上鎖同步后果可想而知。一個典型的VC多線程程序通常面臨以下幾類同步需求控制流同步這是最直觀的需求。線程A必須等待線程B完成某項初始化工作后才能開始執(zhí)行?；蛘呔€程B需要等待線程A發(fā)出一個“開始”信號。這就像生產(chǎn)線上的工人必須等到上道工序完成才能開始自己的工作。事件Event對象是解決這類問題的利器。數(shù)據(jù)訪問同步多個線程需要讀寫同一塊內(nèi)存如全局變量、堆對象、靜態(tài)成員。如果不加保護(hù)就會導(dǎo)致數(shù)據(jù)損壞、讀取到中間狀態(tài)等嚴(yán)重問題。例如一個線程正在寫入一個結(jié)構(gòu)體寫了一半另一個線程就來讀取拿到的是無效數(shù)據(jù)。臨界區(qū)Critical Section、互斥量Mutex和信號量Semaphore主要用于解決這類問題。資源計數(shù)同步有一類資源如數(shù)據(jù)庫連接池、線程池中的工作線程數(shù)量有限。需要一種機(jī)制來管理這些資源的分配與回收確保不會超限使用。信號量Semaphore天生就是為這種場景設(shè)計的。UI線程與工作線程的同步在Windows桌面開發(fā)中這是一個極其重要且特殊的場景。所有與用戶界面窗口、控件的直接交互都必須在主UI線程中進(jìn)行。工作線程不能直接操作UI控件否則極易導(dǎo)致程序崩潰或界面凍結(jié)。工作線程需要通過某種方式如發(fā)送Windows消息、調(diào)用PostMessage將“更新UI”的請求“同步”到主線程去執(zhí)行。我們這個實戰(zhàn)工程將重點攻克控制流同步和UI線程與工作線程的同步并以事件機(jī)制為核心串聯(lián)整個流程。我們會構(gòu)建一個經(jīng)典的生產(chǎn)者-消費者模型變種主線程作為命令的發(fā)起者生產(chǎn)者多個工作線程作為任務(wù)執(zhí)行者消費者通過事件對象來協(xié)調(diào)任務(wù)的開始與結(jié)果的返回。1.2 技術(shù)選型為什么是Windows原生API而非C11std::thread你可能會問C11標(biāo)準(zhǔn)庫不是提供了std::thread、std::mutex、std::condition_variable嗎為什么還要用老舊的Windows API這是一個非常好的問題選擇基于以下幾點考量與Windows系統(tǒng)的深度集成Windows的事件對象HANDLE不僅可以用于線程同步還可以用于與許多其他Windows對象和機(jī)制交互比如WaitForMultipleObjects函數(shù)可以同時等待事件、線程句柄、進(jìn)程句柄、互斥量等多種對象。這種靈活性是標(biāo)準(zhǔn)庫暫時無法比擬的尤其在需要與系統(tǒng)其他部分如I/O完成端口IOCP協(xié)同工作時。明確的超時控制Windows的等待函數(shù)如WaitForSingleObject直接支持毫秒級的超時參數(shù)這在實現(xiàn)“等待一段時間等不到就做別的事”的邏輯時非常方便。雖然C11也能通過std::chrono實現(xiàn)但Windows API的方式更為直接和傳統(tǒng)。工程實踐與遺留代碼大量的現(xiàn)有VC工程特別是MFC、ATL項目廣泛使用了Windows線程和同步API。理解這些API是維護(hù)、優(yōu)化和重構(gòu)這些代碼的基礎(chǔ)。此外在調(diào)試時Windows調(diào)試器對原生線程和同步對象的支持通常更直觀。性能與可控性對于性能極其敏感的場景開發(fā)者可能需要對線程優(yōu)先級、親和性Affinity進(jìn)行更精細(xì)的控制Windows API提供了更底層的接口。當(dāng)然這并不是說std::thread不好。在新啟動的、跨平臺需求明確的現(xiàn)代C項目中標(biāo)準(zhǔn)庫是首選。但本次實戰(zhàn)的目標(biāo)是深入理解Windows平臺多線程編程的核心機(jī)制因此選擇從原生API入手。理解了這些再去看std::condition_variable你會發(fā)現(xiàn)它本質(zhì)上就是事件機(jī)制的一種更高層次的封裝。注意在實際工程中一個常見的良好實踐是在模塊或類內(nèi)部進(jìn)行封裝。你可以用Windows API實現(xiàn)底層的同步原語然后封裝成類似C標(biāo)準(zhǔn)庫接口的類這樣既利用了系統(tǒng)特性又提供了更現(xiàn)代、更安全的接口。我們后續(xù)的示例也會體現(xiàn)這一思想。2. 核心同步對象深度解析事件、臨界區(qū)與信號量在動手寫代碼之前我們必須對將要使用的幾個核心“工具”有透徹的理解。它們就像木匠手中的鋸、刨、鑿各有各的用途用錯了地方要么事倍功半要么直接搞砸。2.1 事件Event對象線程間的“信號燈”事件對象是Windows線程同步中最靈活、最常用的機(jī)制之一。你可以把它想象成一個布爾狀態(tài)標(biāo)志附帶一個等待隊列。這個狀態(tài)只有兩種已通知Signaled和未通知Non-signaled。創(chuàng)建HANDLE CreateEvent(...)。關(guān)鍵參數(shù)是bManualReset和bInitialState。bManualReset決定事件是“手動重置”還是“自動重置”。手動重置事件TRUE事件被SetEvent置為已通知狀態(tài)后會一直保持這個狀態(tài)直到顯式調(diào)用ResetEvent將其重置為未通知狀態(tài)。在此期間所有等待該事件的線程都會被釋放繼續(xù)執(zhí)行。它像是一個閘門打開后所有人都能通過直到你手動關(guān)上。自動重置事件FALSE事件被SetEvent置為已通知狀態(tài)后只會釋放一個正在等待的線程然后自動重置為未通知狀態(tài)。如果有多個線程在等待只有一個能“搶到”并繼續(xù)執(zhí)行事件隨即關(guān)閉。它像是一個旋轉(zhuǎn)閘機(jī)一次只放行一個人。bInitialState事件的初始狀態(tài)TRUE為已通知FALSE為未通知。設(shè)置信號BOOL SetEvent(HANDLE hEvent)。將事件對象狀態(tài)設(shè)為已通知。重置信號BOOL ResetEvent(HANDLE hEvent)。將事件對象狀態(tài)設(shè)為未通知。主要用于手動重置事件。等待信號DWORD WaitForSingleObject(HANDLE hHandle, DWORD dwMilliseconds)。當(dāng)前線程會掛起不消耗CPU直到hHandle所指的對象變?yōu)橐淹ㄖ獱顟B(tài)或者超時。dwMilliseconds可以指定超時時間毫秒INFINITE表示無限等待。實戰(zhàn)場景選擇用自動重置事件實現(xiàn)“一對一”通知比如主線程通知一個特定的工作線程開始工作。工作線程在WaitForSingleObject上阻塞主線程SetEvent工作線程被喚醒事件自動重置準(zhǔn)備下一次通知。這避免了多個線程被意外同時喚醒。用手動重置事件實現(xiàn)“一對多”通知比如初始化完成后需要同時喚醒所有等待初始化完成的工作線程。主線程SetEvent后所有等待線程同時繼續(xù)執(zhí)行。之后需要調(diào)用ResetEvent來為下一輪等待做準(zhǔn)備。2.2 臨界區(qū)Critical Section輕量級的“房間鎖”臨界區(qū)用于保護(hù)一段代碼臨界區(qū)代碼確保同一時間只有一個線程可以進(jìn)入執(zhí)行。它比互斥量Mutex更輕量但只能用于同一進(jìn)程內(nèi)的線程同步。初始化InitializeCriticalSection或InitializeCriticalSectionAndSpinCount。進(jìn)入EnterCriticalSection。如果臨界區(qū)空閑當(dāng)前線程進(jìn)入如果已被占用當(dāng)前線程阻塞等待。嘗試進(jìn)入TryEnterCriticalSection。非阻塞版本成功進(jìn)入返回TRUE否則返回FALSE。離開LeaveCriticalSection。線程離開臨界區(qū)釋放鎖。刪除DeleteCriticalSection。重要特性臨界區(qū)是“可重入”的。同一個線程可以多次調(diào)用EnterCriticalSection而不會死鎖但必須調(diào)用相同次數(shù)的LeaveCriticalSection來真正釋放。實操心得臨界區(qū)雖然輕量但不當(dāng)使用極易導(dǎo)致死鎖。一個黃金法則是進(jìn)入和離開必須嚴(yán)格配對且確保在離開前所有可能的執(zhí)行路徑包括異常、提前返回都能執(zhí)行到LeaveCriticalSection。在C中通常使用RAII資源獲取即初始化技術(shù)來封裝臨界區(qū)構(gòu)造時加鎖析構(gòu)時解鎖這樣可以完美避免因異常或忘記解鎖導(dǎo)致的問題。我們后續(xù)的封裝示例就會采用這種方法。2.3 信號量Semaphore控制訪問數(shù)量的“計數(shù)器”信號量維護(hù)一個計數(shù)器用于控制對有限數(shù)量資源的訪問。計數(shù)器初始值代表可用資源數(shù)。線程通過WaitForSingleObject在Windows中信號量也是內(nèi)核對象可等待來申請資源計數(shù)器減1通過ReleaseSemaphore來釋放資源計數(shù)器加1。如果計數(shù)器為0申請資源的線程將阻塞直到有其他線程釋放資源。創(chuàng)建CreateSemaphore需要指定初始計數(shù)和最大計數(shù)。釋放ReleaseSemaphore。信號量非常適合實現(xiàn)線程池、連接池或經(jīng)典的生產(chǎn)者-消費者模型其中緩沖區(qū)有大小限制。在我們的實戰(zhàn)中如果需要限制同時執(zhí)行任務(wù)的工作線程數(shù)量信號量就會派上用場。3. 實戰(zhàn)工程搭建一個基于事件的生產(chǎn)者-消費者模型理論鋪墊完畢現(xiàn)在我們來搭建一個具體的VC控制臺/對話框工程。這個工程模擬一個簡單的任務(wù)處理系統(tǒng)主線程產(chǎn)生任務(wù)多個工作線程競爭獲取并執(zhí)行任務(wù)執(zhí)行完畢后通知主線程。3.1 工程結(jié)構(gòu)與核心類設(shè)計我們設(shè)計兩個核心類CTask任務(wù)和CThreadPool線程池。為了清晰我們先用控制臺項目演示核心邏輯。// Task.h - 任務(wù)基類 #pragma once #include string #include functional // C11如需兼容舊編譯器可自行實現(xiàn) class CTask { public: CTask(int id) : m_nTaskId(id), m_bFinished(false) {} virtual ~CTask() {} int GetId() const { return m_nTaskId; } bool IsFinished() const { return m_bFinished; } // 純虛函數(shù)子類實現(xiàn)具體任務(wù)邏輯 virtual void Execute() 0; // 設(shè)置完成狀態(tài)由工作線程調(diào)用 void SetFinished() { m_bFinished true; } private: int m_nTaskId; bool m_bFinished; }; // 一個簡單的示例任務(wù)計算斐波那契數(shù)列 class CFibonacciTask : public CTask { public: CFibonacciTask(int id, int n) : CTask(id), m_nInput(n), m_nResult(0) {} virtual void Execute() override { // 模擬耗時計算 m_nResult CalcFibonacci(m_nInput); SetFinished(); printf(Worker Thread [%lu]: Task %d finished, result %d\n, GetCurrentThreadId(), GetId(), m_nResult); } int GetResult() const { return m_nResult; } private: int CalcFibonacci(int n) { if (n 1) return n; int a 0, b 1; for (int i 2; i n; i) { int c a b; a b; b c; // 模擬計算耗時 Sleep(10); } return b; } int m_nInput; int m_nResult; };接下來是線程池的核心。這里我們會用到事件和臨界區(qū)。// ThreadPool.h #pragma once #include vector #include queue #include windows.h #include Task.h class CThreadPool { public: CThreadPool(int nWorkerCount); ~CThreadPool(); // 啟動所有工作線程 bool Start(); // 停止所有工作線程優(yōu)雅退出 void Stop(); // 添加任務(wù)到隊列 void AddTask(CTask* pTask); // 獲取已完成任務(wù)主線程調(diào)用 CTask* GetFinishedTask(); private: // 工作線程的靜態(tài)函數(shù)用于調(diào)用成員函數(shù) static DWORD WINAPI WorkerThreadProc(LPVOID lpParam); // 實際的工作線程函數(shù) void WorkerThread(); // 同步對象 CRITICAL_SECTION m_csTaskQueue; // 保護(hù)任務(wù)隊列 HANDLE m_hNewTaskEvent; // 自動重置事件通知有新任務(wù) HANDLE m_hQuitEvent; // 手動重置事件通知線程退出 // 線程與任務(wù)管理 std::vectorHANDLE m_vecWorkerThreads; std::queueCTask* m_qPendingTasks; // 待處理任務(wù)隊列 std::queueCTask* m_qFinishedTasks; // 已完成任務(wù)隊列 int m_nWorkerCount; bool m_bRunning; };3.2 核心同步邏輯實現(xiàn)讓我們深入ThreadPool.cpp看看同步是如何具體實現(xiàn)的。// ThreadPool.cpp #include ThreadPool.h #include iostream CThreadPool::CThreadPool(int nWorkerCount) : m_nWorkerCount(nWorkerCount), m_bRunning(false) { // 初始化臨界區(qū) InitializeCriticalSection(m_csTaskQueue); // 創(chuàng)建事件對象 // m_hNewTaskEvent: 自動重置初始無信號。一個任務(wù)到來只喚醒一個線程。 m_hNewTaskEvent CreateEvent(NULL, FALSE, FALSE, NULL); // m_hQuitEvent: 手動重置初始無信號。當(dāng)需要退出時設(shè)置為有信號所有等待線程都會看到并退出。 m_hQuitEvent CreateEvent(NULL, TRUE, FALSE, NULL); if (m_hNewTaskEvent NULL || m_hQuitEvent NULL) { std::cerr Failed to create event objects! std::endl; } } CThreadPool::~CThreadPool() { Stop(); // 確保線程池已停止 DeleteCriticalSection(m_csTaskQueue); if (m_hNewTaskEvent) CloseHandle(m_hNewTaskEvent); if (m_hQuitEvent) CloseHandle(m_hQuitEvent); } bool CThreadPool::Start() { if (m_bRunning) return true; // 重置退出事件確保它是無信號的 ResetEvent(m_hQuitEvent); m_bRunning true; m_vecWorkerThreads.reserve(m_nWorkerCount); for (int i 0; i m_nWorkerCount; i) { // 創(chuàng)建線程將this指針作為參數(shù)傳入 HANDLE hThread CreateThread( NULL, // 默認(rèn)安全屬性 0, // 默認(rèn)堆棧大小 WorkerThreadProc, // 線程函數(shù) (LPVOID)this, // 傳遞給線程的參數(shù) 0, // 默認(rèn)創(chuàng)建標(biāo)志 NULL // 不需要線程ID ); if (hThread) { m_vecWorkerThreads.push_back(hThread); } else { std::cerr Failed to create worker thread i std::endl; // 簡化處理如果創(chuàng)建失敗停止已創(chuàng)建的線程 Stop(); return false; } } std::cout ThreadPool started with m_nWorkerCount workers. std::endl; return true; } void CThreadPool::Stop() { if (!m_bRunning) return; m_bRunning false; // 1. 設(shè)置退出事件通知所有工作線程 SetEvent(m_hQuitEvent); // 2. 等待所有工作線程結(jié)束 DWORD dwWait WaitForMultipleObjects( (DWORD)m_vecWorkerThreads.size(), m_vecWorkerThreads[0], TRUE, // 等待所有線程 5000 // 等待5秒 ); if (dwWait WAIT_TIMEOUT) { std::cerr Warning: Some worker threads did not exit gracefully, forcing termination. std::endl; // 超時強(qiáng)制終止線程不推薦但作為兜底 for (HANDLE hThread : m_vecWorkerThreads) { TerminateThread(hThread, 0); } } // 3. 關(guān)閉線程句柄 for (HANDLE hThread : m_vecWorkerThreads) { CloseHandle(hThread); } m_vecWorkerThreads.clear(); // 4. 清理任務(wù)隊列簡單起見這里直接刪除實際項目可能需要更復(fù)雜的清理邏輯 EnterCriticalSection(m_csTaskQueue); while (!m_qPendingTasks.empty()) { delete m_qPendingTasks.front(); m_qPendingTasks.pop(); } while (!m_qFinishedTasks.empty()) { delete m_qFinishedTasks.front(); m_qFinishedTasks.pop(); } LeaveCriticalSection(m_csTaskQueue); std::cout ThreadPool stopped. std::endl; } // 靜態(tài)成員函數(shù)作為線程入口點 DWORD WINAPI CThreadPool::WorkerThreadProc(LPVOID lpParam) { CThreadPool* pThis (CThreadPool*)lpParam; pThis-WorkerThread(); return 0; } // 工作線程的核心循環(huán) void CThreadPool::WorkerThread() { DWORD dwWaitResult; HANDLE waitHandles[2]; waitHandles[0] m_hNewTaskEvent; // 索引0新任務(wù)事件 waitHandles[1] m_hQuitEvent; // 索引1退出事件 while (m_bRunning) { // 等待兩個事件中的任意一個變?yōu)橛行盘枲顟B(tài) dwWaitResult WaitForMultipleObjects(2, waitHandles, FALSE, INFINITE); switch (dwWaitResult) { case WAIT_OBJECT_0: { // m_hNewTaskEvent 有信號了有新任務(wù) CTask* pTask NULL; // 從待處理隊列中取出一個任務(wù) EnterCriticalSection(m_csTaskQueue); if (!m_qPendingTasks.empty()) { pTask m_qPendingTasks.front(); m_qPendingTasks.pop(); } // 重要如果隊列已空重置事件為無信號避免其他線程被無意義喚醒 // 但由于是自動重置事件在喚醒一個線程后已自動重置。這里需要判斷是否還有任務(wù)。 // 更嚴(yán)謹(jǐn)?shù)淖龇ㄊ窃贏ddTask時如果添加前隊列為空則SetEvent。 // 在取出任務(wù)后如果隊列不為空則再次SetEvent以喚醒下一個線程。 // 為了簡化本例采用“喚醒-取一個”的模式事件由AddTask觸發(fā)。 LeaveCriticalSection(m_csTaskQueue); if (pTask) { // 執(zhí)行任務(wù) pTask-Execute(); // 將已完成的任務(wù)放入完成隊列 EnterCriticalSection(m_csTaskQueue); m_qFinishedTasks.push(pTask); LeaveCriticalSection(m_csTaskQueue); } break; } case WAIT_OBJECT_0 1: // m_hQuitEvent 有信號了要求退出 std::cout Worker Thread [ GetCurrentThreadId() ] exiting. std::endl; return; // 退出線程函數(shù) case WAIT_TIMEOUT: // 不會發(fā)生因為INFINITE break; default: // 等待失敗 std::cerr WaitForMultipleObjects failed: GetLastError() std::endl; return; } } } void CThreadPool::AddTask(CTask* pTask) { if (!pTask) return; EnterCriticalSection(m_csTaskQueue); bool bWasEmpty m_qPendingTasks.empty(); m_qPendingTasks.push(pTask); LeaveCriticalSection(m_csTaskQueue); // 關(guān)鍵同步點如果添加任務(wù)前隊列是空的說明可能有線程在等待。 // 此時觸發(fā)事件喚醒一個等待的工作線程。 if (bWasEmpty) { SetEvent(m_hNewTaskEvent); } } CTask* CThreadPool::GetFinishedTask() { CTask* pTask NULL; EnterCriticalSection(m_csTaskQueue); if (!m_qFinishedTasks.empty()) { pTask m_qFinishedTasks.front(); m_qFinishedTasks.pop(); } LeaveCriticalSection(m_csTaskQueue); return pTask; }3.3 主程序邏輯與測試最后我們編寫一個簡單的main函數(shù)來測試這個線程池。// main.cpp #include ThreadPool.h #include Task.h #include iostream #include chrono int main() { std::cout Visual C ThreadPool with Event Demo std::endl; // 創(chuàng)建一個包含4個工作線程的線程池 CThreadPool pool(4); if (!pool.Start()) { std::cerr Failed to start thread pool! std::endl; return -1; } // 添加10個任務(wù) for (int i 0; i 10; i) { CFibonacciTask* pTask new CFibonacciTask(i, 30 i); // 計算斐波那契數(shù)列第30i項 pool.AddTask(pTask); std::cout Main Thread: Added task i std::endl; Sleep(50); // 主線程稍微延遲模擬任務(wù)產(chǎn)生間隔 } // 主線程等待并收集結(jié)果 int finishedCount 0; while (finishedCount 10) { // 非阻塞地獲取已完成任務(wù) CTask* pFinished pool.GetFinishedTask(); if (pFinished) { CFibonacciTask* pFibTask dynamic_castCFibonacciTask*(pFinished); if (pFibTask) { std::cout Main Thread: Got result for task pFinished-GetId() , result pFibTask-GetResult() std::endl; } delete pFinished; // 清理任務(wù)對象 finishedCount; } else { // 沒有已完成任務(wù)主線程可以做一些其他工作或者短暫休眠 Sleep(100); std::cout Main Thread: Waiting for tasks to complete... std::endl; } } std::cout All tasks finished. Stopping thread pool... std::endl; pool.Stop(); std::cout Demo finished. std::endl; system(pause); return 0; }運行邏輯解析啟動線程池啟動4個工作線程它們都阻塞在WaitForMultipleObjects上等待m_hNewTaskEvent新任務(wù)或m_hQuitEvent退出信號。投遞任務(wù)主線程循環(huán)創(chuàng)建并投遞10個任務(wù)。每次投遞時如果任務(wù)隊列之前是空的bWasEmpty為true就調(diào)用SetEvent(m_hNewTaskEvent)。這個自動重置事件會喚醒一個且僅一個等待的工作線程。工作線程處理被喚醒的工作線程從隊列中取出一個任務(wù)受臨界區(qū)保護(hù)執(zhí)行模擬計算然后將完成的任務(wù)放入完成隊列。主線程收集主線程在投遞完任務(wù)后循環(huán)從完成隊列中取出任務(wù)打印結(jié)果。這里主線程沒有阻塞等待而是采用輪詢的方式中間可以Sleep或處理其他邏輯。優(yōu)雅停止所有任務(wù)完成后主線程調(diào)用pool.Stop()。Stop函數(shù)首先設(shè)置m_hQuitEvent手動重置事件這個信號會被所有正在WaitForMultipleObjects的工作線程接收到因為m_hQuitEvent在等待數(shù)組中。工作線程收到退出信號后跳出循環(huán)線程函數(shù)結(jié)束。主線程再使用WaitForMultipleObjects等待所有工作線程句柄結(jié)束最后清理資源。4. 進(jìn)階與UI線程MFC/Win32的安全交互上面的例子是控制臺程序主線程和工作線程都是平等的。但在有GUI的應(yīng)用程序中主線程是UI線程直接在工作線程中更新UI控件是絕對禁止的會導(dǎo)致界面卡頓甚至程序崩潰。我們必須將更新UI的請求“封送”Marshal到UI線程去執(zhí)行。4.1 使用Windows消息機(jī)制MFC為例在MFC中最標(biāo)準(zhǔn)的方式是使用自定義消息和PostMessage/SendMessage。定義自定義消息// 在stdafx.h或某個頭文件中 #define WM_USER_TASK_FINISHED (WM_USER 100)在工作線程中通知UI 工作線程不能直接調(diào)用窗口類的方法。它需要獲取UI窗口的句柄HWND然后發(fā)送消息。// 假設(shè)我們將主窗口句柄保存在線程池或通過參數(shù)傳遞給任務(wù) // 在CFibonacciTask::Execute()末尾添加 void CFibonacciTask::Execute() override { // ... 計算邏輯 ... SetFinished(); printf(...); // 控制臺輸出 // 通知UI線程 if (m_hWndNotify ! NULL) { // m_hWndNotify是任務(wù)創(chuàng)建時傳入的主窗口句柄 // 使用PostMessage異步不阻塞工作線程 ::PostMessage(m_hWndNotify, WM_USER_TASK_FINISHED, (WPARAM)GetId(), (LPARAM)m_nResult); } }在UI窗口類中處理消息 在主窗口類的頭文件中聲明消息處理函數(shù)并在消息映射中添加條目。// MainFrm.h class CMainFrame : public CFrameWnd { // ... protected: afx_msg LRESULT OnTaskFinished(WPARAM wParam, LPARAM lParam); DECLARE_MESSAGE_MAP() }; // MainFrm.cpp BEGIN_MESSAGE_MAP(CMainFrame, CFrameWnd) ON_MESSAGE(WM_USER_TASK_FINISHED, CMainFrame::OnTaskFinished) END_MESSAGE_MAP() LRESULT CMainFrame::OnTaskFinished(WPARAM wParam, LPARAM lParam) { int nTaskId (int)wParam; int nResult (int)lParam; // 現(xiàn)在是在UI線程中了可以安全地操作控件 CString strMsg; strMsg.Format(_T(Task %d finished with result: %d), nTaskId, nResult); GetStatusBar().SetPaneText(0, strMsg); // 更新狀態(tài)欄 // 或者更新列表控件等 return 0; }4.2 使用PostMessage與SendMessage的抉擇PostMessage將消息放入UI線程的消息隊列后立即返回。異步操作不會阻塞工作線程。這是跨線程更新UI的首選和必須方式。SendMessage直接調(diào)用UI線程的消息處理函數(shù)等待其處理完畢后才返回。同步操作會阻塞工作線程直到UI線程處理完該消息。絕對不要在工作線程中使用SendMessage發(fā)送給UI線程這極易引起死鎖如果UI線程也在等待工作線程的某個信號。實操心得傳遞復(fù)雜數(shù)據(jù)時不要直接通過WPARAM和LPARAM傳遞指針因為指針?biāo)傅膬?nèi)存可能在工作線程結(jié)束后被釋放導(dǎo)致UI線程訪問非法內(nèi)存。正確的做法是要么傳遞簡單的值類型數(shù)據(jù)如ID、結(jié)果值要么使用線程安全的機(jī)制傳遞數(shù)據(jù)副本例如通過消息傳遞一個std::shared_ptr指向的數(shù)據(jù)對象需要確保該對象的生命周期管理是線程安全的或者使用PostMessage發(fā)送一個“數(shù)據(jù)準(zhǔn)備好”的消息然后UI線程再去一個線程安全的隊列中取數(shù)據(jù)。5. 常見陷阱、調(diào)試技巧與性能考量多線程編程充滿陷阱以下是一些VC開發(fā)者常踩的坑及應(yīng)對策略。5.1 死鎖Deadlock與預(yù)防死鎖通常發(fā)生在兩個或多個線程互相等待對方持有的鎖。例如線程A鎖定了臨界區(qū)1試圖鎖定臨界區(qū)2。線程B鎖定了臨界區(qū)2試圖鎖定臨界區(qū)1。結(jié)果兩者都永遠(yuǎn)等下去。預(yù)防策略固定鎖順序所有線程都按照相同的全局順序如先鎖A再鎖B來獲取鎖。這是最有效的方法之一。使用TryEnterCriticalSection在嘗試獲取第二個鎖時使用非阻塞版本如果失敗則釋放已持有的鎖回退并重試。縮小鎖范圍鎖粒度只鎖住真正需要保護(hù)的共享數(shù)據(jù)區(qū)域盡快釋放鎖。避免在持鎖的情況下進(jìn)行耗時操作如I/O、網(wǎng)絡(luò)請求。使用更高級的同步原語有時用信號量或事件可以重構(gòu)邏輯避免復(fù)雜的鎖嵌套。5.2 資源泄漏Resource Leak句柄泄漏CreateEvent、CreateThread、CreateMutex等返回的HANDLE必須用CloseHandle關(guān)閉。MFC的線程函數(shù)AfxBeginThread返回的CWinThread*指針也需要正確管理。臨界區(qū)泄漏InitializeCriticalSection必須與DeleteCriticalSection配對。內(nèi)存泄漏線程中分配的內(nèi)存new/malloc必須在線程退出前釋放或者所有權(quán)轉(zhuǎn)移到其他線程。調(diào)試技巧使用Visual Studio的內(nèi)存診斷工具和“診斷工具”窗口中的“內(nèi)存使用量”和“線程”視圖監(jiān)控句柄數(shù)和內(nèi)存增長。對于臨界區(qū)可以檢查是否每個Enter都有對應(yīng)的Leave。5.3 虛假喚醒Spurious Wakeup雖然Windows的WaitForSingleObject等函數(shù)對內(nèi)核對象的等待不容易發(fā)生虛假喚醒但當(dāng)你使用條件變量如C11的std::condition_variable時這是一個必須考慮的問題。解決方案總是在等待條件變量的循環(huán)中檢查條件謂詞而不是簡單的if語句。// 正確做法 std::unique_lockstd::mutex lock(mtx); while (!taskAvailable) { // 使用while循環(huán)檢查條件 cond.wait(lock); } // 處理任務(wù)在我們的Windows事件示例中由于我們等待的是明確的內(nèi)核對象信號通常不涉及此問題。但良好的習(xí)慣是在從等待中返回后再次檢查我們等待的條件是否真正滿足例如從隊列取任務(wù)前再次判斷隊列是否非空。5.4 性能優(yōu)化點避免鎖競爭鎖是性能殺手。如果共享數(shù)據(jù)頻繁讀寫考慮無鎖數(shù)據(jù)結(jié)構(gòu)適用于特定場景實現(xiàn)復(fù)雜。讀寫鎖SRW LockWindows Vista及以上提供了InitializeSRWLock,AcquireSRWLockShared,AcquireSRWLockExclusive等API允許多個讀線程并發(fā)寫線程獨占。線程局部存儲TLS如果數(shù)據(jù)不需要在線程間共享使用TLS是零競爭的最佳選擇。線程數(shù)量與CPU核心數(shù)創(chuàng)建遠(yuǎn)超物理核心數(shù)的線程會導(dǎo)致大量的上下文切換開銷反而降低性能。通常CPU核心數(shù) 1或CPU核心數(shù) * 2是一個不錯的起點對于I/O密集型任務(wù)可以更多。可以用GetSystemInfo獲取核心數(shù)。使用I/O完成端口IOCP對于高性能網(wǎng)絡(luò)服務(wù)器或磁盤I/O密集型應(yīng)用IOCP是Windows上最高效的異步I/O和線程池模型它內(nèi)部實現(xiàn)了復(fù)雜的線程調(diào)度能最大程度減少上下文切換。這是進(jìn)階的方向。5.5 Visual Studio多線程調(diào)試“線程”窗口調(diào)試時點擊“調(diào)試”-“窗口”-“線程”可以查看所有線程的ID、狀態(tài)、調(diào)用棧?？梢詢鼋Y(jié)暫停或恢復(fù)特定線程這對分析死鎖極其有用。并行堆棧在“調(diào)試”-“窗口”-“并行堆棧”中可以圖形化地查看所有線程的調(diào)用堆?？焖倭私饩€程間的協(xié)作與等待關(guān)系。條件斷點與篩選器可以為斷點設(shè)置條件如Thread::Id 1234或篩選器如ThreadName WorkerThread只在特定線程命中斷點。數(shù)據(jù)斷點可以監(jiān)視特定內(nèi)存地址的讀寫當(dāng)多線程錯誤修改共享變量時能立刻中斷并定位到修改它的線程。多線程同步是VC開發(fā)中構(gòu)建穩(wěn)健、高效應(yīng)用程序的基石。從理解事件、臨界區(qū)這些基礎(chǔ)內(nèi)核對象開始到設(shè)計出清晰的生產(chǎn)者-消費者模型再到解決UI線程交互的難題每一步都需要仔細(xì)考量。記住多線程編程的第一原則是簡單清晰在能滿足需求的前提下同步機(jī)制越簡單越好。當(dāng)程序出現(xiàn)詭異的、難以復(fù)現(xiàn)的bug時多線程問題往往是首要懷疑對象。扎實地掌握本文所述的原理和實踐能幫你構(gòu)建出既快又穩(wěn)的Windows桌面應(yīng)用。