在用戶(hù)線(xiàn)程/主線(xiàn)程中推薦MsgWaitForMultipleObjects代替WaitForSingleObject和WaitForMultipleObjects()函數
在多線(xiàn)程編程中，通常都需要線(xiàn)程間的同步，一個(gè)線(xiàn)程要等待另一個(gè)線(xiàn)程的事件才繼續執行，一般的做法是采用WaitForSingleObject和WaitForMultipleObjects()函數來(lái)實(shí)現。
但在實(shí)際的應用中，經(jīng)常出現等待線(xiàn)程卡死的狀況，也就是說(shuō)等待的事件一直無(wú)效。為什么事件一直無(wú)效呢？很多的情況是等待線(xiàn)程阻塞了另外的線(xiàn)程，使另外的線(xiàn)程無(wú)法設置事件有效。為什么會(huì )阻塞呢？原因就比較多了，需要具體問(wèn)題具體分析。
WaitForSingleObject和WaitForMultipleObjects()都是阻塞函數，事件無(wú)效就一直不返回，從而阻塞該線(xiàn)程，使該線(xiàn)程無(wú)法處理其他的事務(wù)，如果其他的線(xiàn)程發(fā)送消息過(guò)來(lái)，將得不到處理而不返回，從而將其他的線(xiàn)程也阻塞，造成相互等待，這就是臭名昭著(zhù)的“死鎖”?。?！
微軟提供了另外一個(gè)函數可以解決該問(wèn)題，它就是MsgWaitForMultipleObjects()函數，該函數不但可以等待事件，還可以等待消息，從而處理消息，使線(xiàn)程不阻塞。該函數的具體解釋前參考MSDN或網(wǎng)絡(luò )。
一般的使用方法為：
- DWORD dwRet = 0;
- MSG msg;
- DWORD dwStartTime = GetTickCount();
- while (TRUE)
- {
- //超時(shí)判斷 5s
- dwRet = GetTickCount() - dwStartTime;
- if ((GetTickCount() - dwStartTime) > 10000)
- {
- AfxMessageBox(_T("獲取數據超時(shí)，請檢測設備網(wǎng)絡(luò )連接!"), MB_OK | MB_ICONERROR);
- return NULL;
- }
-
- //wait for m_hThread to be over，and wait for
- //QS_ALLINPUT（Any message is in the queue）
- //dwRet = WaitForSingleObject(g_hRetEvent, INFINITE);
- dwRet = MsgWaitForMultipleObjects (1, &g_hRetEvent, FALSE, 100, QS_ALLINPUT);
- switch(dwRet)
- {
- case WAIT_OBJECT_0: //返回數據達到
- break; //break the loop
- case WAIT_OBJECT_0 + 1: //界面消息
- //get the message from Queue
- //and dispatch it to specific window
- if (PeekMessage(&msg, NULL, 0, 0, PM_REMOVE))
- {
- TranslateMessage(&msg);
- DispatchMessage(&msg);
- }
- continue;
- case WAIT_TIMEOUT: //超時(shí)
- continue;
- default:
- AfxMessageBox(_T("數據獲取失敗，未知錯誤!"), MB_OK | MB_ICONERROR);
- return NULL;
- break; // unexpected failure
- }
- break;
- }
特別是在主線(xiàn)程和界面線(xiàn)程中推薦使用該函數，可以避免很多麻煩?。?！
本站僅提供存儲服務(wù)，所有內容均由用戶(hù)發(fā)布，如發(fā)現有害或侵權內容，請
點(diǎn)擊舉報。
