有時候我們想在一個類中實現多線程，主線程在某些時刻獲得數據，可以“通知”子線程去處理，然後把結果返回。下面的實例是主線程每隔2s產生10個隨機數，將這10隨機數傳給多線程類，讓它接收到數據後馬上打印出來。

首先看類的定義：

1. #pragma once
2. #include <iostream>
3. #include <atlbase.h> // 使用到了atl類
4. #include <atlsync.h>
5. #include <vector>
6. using namespace std;
8. class CMultiThreadTest
9. {
10. public:
11. bool Init(); // 初始化類成員
12. bool UnInit(); // 釋放資源
13. void NotifyDowork(const std::vector<int> &data);
15. static DWORD CALLBACK TestThread(LPVOID); // 線程函數，必須是靜態函數
16. DWORD TestProc(); // 線程工作實現
18. private:
19. std::vector<int> m_data; // 同步數據
20. ATL::CEvent m_NotifyEvent; // 通知事件
21. HANDLE m_hThread; // 線程句柄
22. };

類中使用到了ALT類，需要包含atlbase.h和altsync.h頭文件。函數TestThread必須是靜態函數，因為CreateThread只接受全局或者靜態函數。
首先先看Init()和UnInit()函數的實現：

1. bool CMultiThreadTest::Init()
2. {
3. // 創建事件
4. BOOL bRet = m_NotifyEvent.Create(NULL, TRUE, FALSE, NULL);
5. if (!bRet) {
6. return false;
7. }
9. // 掛起的方式創建線程
10. m_hThread = CreateThread(NULL, 0, &CMultiThreadTest::TestThread, this, CREATE_SUSPENDED, NULL);
11. if (NULL == m_hThread) {
12. return false;
13. }
15. // 喚醒線程
16. ResumeThread(m_hThread);
17. return true;
18. }
21. bool CMultiThreadTest::UnInit()
22. {
23. // 通知線程處理data的數據
24. if (m_NotifyEvent != NULL) {
25. m_NotifyEvent.Set();
26. }
28. if (m_hThread != NULL)
29. {
30. // 預留100ms讓線程處理完數據，100ms是個估值
31. WaitForSingleObject(m_hThread, 100);
32. CloseHandle(m_hThread);
33. m_hThread = NULL;
34. }
36. return true;
37. }

ATL::CEvent的成員函數Create接收4個參數，第四個參數指定Event的名字（它是可以有名字的），以便在其他進程可以找到該事件，這裏我們不需要使用，把它設置為NULL，其他參數很容易理解，不贅述。
Init()函數值得註意的是我們創建的線程是以掛起的方式創建，所以必須調用ResumeThread喚醒線程，否則線程一值處於沈睡狀態，不執行線程函數。
UnInit()函數比較簡單，主要通知線程執行收尾工作，並釋放類的資源。

下面我們來看看剩下的函數的實現。

1. DWORD CALLBACK CMultiThreadTest::TestThread(LPVOID lpParam)
2. {
3. if (lpParam == NULL) {
4. return 0;
5. }
7. CMultiThreadTest *lpThis = reinterpret_cast<CMultiThreadTest *>(lpParam);
8. return lpThis->TestProc();
9. }
12. DWORD CMultiThreadTest::TestProc()
13. {
14. while (true)
15. {
16. // 每5s監聽一次，秒數直接影響程序的性能
17. DWORD dwRet = WaitForSingleObject(m_NotifyEvent, 5000);
19. // 進入循環5s沒有事件發生，不做任何處理
20. if (dwRet == WAIT_TIMEOUT) {
21. continue;
22. }
24. // 打印數組
25. for (unsigned int i = 0; i < m_data.size(); i++)
26. {
27. cout <<m_data[i] <<" ";
28. }
30. cout <<endl;
32. // 重置事件
33. m_NotifyEvent.Reset();
34. }
35. return 0;
36. }
39. void CMultiThreadTest::NotifyDowork(const std::vector<int> &data)
40. {
41. m_data = data;
42. m_NotifyEvent.Set(); // 通知線程該做事情了！
43. }

首先我們看TestThread函數，它是線程的“入口“，線程被喚醒後執行該函數。值得註意的是，我們在創建線程的時候把對象指針this作為參數傳遞給創建線程函數，系統在調用TestThread的時候會把this傳遞回來，這裏使用弱類型轉換reinterpret_cast將LPVOID轉化為CMultiThreadTest類的指針，reinterpret_cast是一個危險的類型轉換，一般只適用於指針和整數之間的轉換。有興趣的同學可以參考C++ Primer第4版18.2.1章節。

線程函數將參數lpParam轉化為對象指針後，執行對象的成員函數TestProc()，TestProc()實現主要的邏輯。這裏可能會有人疑問，為什麽不直接在TestThread()函數實現主要邏輯呢？這樣做有兩個好處，一是能夠將線程函數邏輯和業務邏輯分離，其二就是TestThread是個靜態函數，類靜態函數只能處理類的靜態成員變量，而很多時候我們希望線程處理類的非靜態成員變量。
最後NotifyDowork函數很簡單，該函數給外部調用，它把外部傳進來的data賦值給類的非靜態成員變量m_data，並通知線程處理m_data數據，TestProc中WaitForSingleObject函數接收到事件後往下執行，把m_data打印出來。

下面我們看看main函數的實現：

1. int _tmain(int argc, _TCHAR* argv[])
2. {
3. CMultiThreadTest multiThreadTest;
5. // 初始化失敗
6. if (!multiThreadTest.Init()) {
7. return 0;
8. }
10. srand(unsigned int(time(NULL)));
11. std::vector<int> data;
13. while (true)
14. {
15. data.clear();
17. // 產生10個隨機數
18. for (int i = 0; i < 10; i++)
19. data.push_back(rand() % 1000);
21. // 通知多線程類執行工作
22. multiThreadTest.NotifyDowork(data);
24. Sleep(2000);
25. }
27. multiThreadTest.UnInit();
28. return 0;
29. }

這段代碼就不用解釋了，記得包含頭文件windows.h、time.h和vector。

總結：
多線程類的使用場景是，當一個線程或得到數據後，希望其他線程能夠處理這部分數。多線程類實現還是比較簡單的，首先創建線程和線程事件，實現給外部調用的接口，外部通過接口設置事件，通知線程執行。

windows編程 使用C++實現多線程類