MFC 多線程及線程同步

一、MFC對多線程編程的支持

　　MFC中有兩類線程，分別稱之為工作者線程和用戶界麵線程。二者的主要區別在於工作者線程沒有消息循環，而用戶界麵線程有自己的消息隊列和消息循環。
　　工作者線程沒有消息機製，通常用來執行後台計算和維護任務，如冗長的計算過程，打印機的後台打印等。用戶界麵線程一般用於處理獨立於其他線程執行之外的用戶輸入，響應用戶及係統所產生的事件和消息等。但對於Win32的API編程而言，這兩種線程是沒有區別的，它們都隻需線程的啟動地址即可啟動線程來執行任務。
　　在MFC中，一般用全局函數AfxBeginThread()來創建並初始化一個線程的運行，該函數有兩種重載形式，分別用於創建工作者線程和用戶界麵線程。兩種重載函數原型和參數分別說明如下：

　　(1) CWinThread* AfxBeginThread(

　　　　　　 AFX_THREADPROC pfnThreadProc,
       　　　　 LPVOID pParam,
       　　　　int nPriority = THREAD_PRIORITY_NORMAL,
       　　　　 UNT nStackSize = 0,
       　　　　 DWORD dwCreateFlags = 0,
       　　　　 LPSECURITY_ATTRIBUTES lpSecurityAttrs = NULL
      　　　　 );//用於創建工作者線程

　　PfnThreadProc:指向工作者線程的執行函數的指針，線程函數原型必須聲明如下：

　　UINT ExecutingFunction(LPVOID pParam);

　　請注意，ExecutingFunction()應返回一個UINT類型的值，用以指明該函數結束的原因。一般情況下，返回0表明執行成功。

pParam：　　一個32位參數，執行函數將用某種方式解釋該值。它可以是數值，或是指向一個結構的指針，甚至可以被忽略；
nPriority：　　線程的優先級。如果為0，則線程與其父線程具有相同的優先級；
nStackSize:　　線程為自己分配堆棧的大小，其單位為字節。如果nStackSize被設為0，則線程的堆棧被設置成與父線程堆棧相同大小；
dwCreateFlags：如果為0，則線程在創建後立刻開始執行。如果為CREATE_SUSPEND，則線程在創建後立刻被掛起；
lpSecurityAttrs：線程的安全屬性指針，一般為NULL；

　　(2) CWinThread* AfxBeginThread(

　　　　　　 CRuntimeClass* pThreadClass,
       　　　　int nPriority = THREAD_PRIORITY_NORMAL,
       　　　　 UNT nStackSize = 0,
       　　　　 DWORD dwCreateFlags = 0,
       　　　　 LPSECURITY_ATTRIBUTES lpSecurityAttrs = NULL
      　　　　 );　

　　pThreadClass 是指向 CWinThread 的一個導出類的運行時類對象的指針，該導出類定義了被創建的用戶界麵線程的啟動、退出等；其它參數的意義同形式1。使用函數的這個原型生成的線程也有消息機製，在以後的例子中我們將發現同主線程的機製幾乎一樣。

　　下麵我們對CWinThread類的數據成員及常用函數進行簡要說明。

m_hThread：　當前線程的句柄；
m_nThreadID: 　當前線程的ID；
m_pMainWnd：　指向應用程序主窗口的指針

　　BOOL CWinThread::CreateThread(DWORD dwCreateFlags=0,UINT nStackSize=0,LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);

　　該函數中的dwCreateFlags、nStackSize、lpSecurityAttrs參數和API函數CreateThread中的對應參數有相同含義，該函數執行成功，返回非0值，否則返回0。
　　一般情況下，調用AfxBeginThread()來一次性地創建並啟動一個線程，但是也可以通過兩步法來創建線程：首先創建CWinThread類的一個對象，然後調用該對象的成員函數CreateThread()來啟動該線程。

　　virtual BOOL CWinThread::InitInstance();

　　重載該函數以控製用戶界麵線程實例的初始化。初始化成功則返回非0值，否則返回0。用戶界麵線程經常重載該函數，工作者線程一般不使用InitInstance()。

　　virtual int CWinThread::ExitInstance();

　　在線程終結前重載該函數進行一些必要的清理工作。該函數返回線程的退出碼，0表示執行成功，非0值用來標識各種錯誤。同InitInstance()成員函數一樣，該函數也隻適用於用戶界麵線程。

二、MFC中線程同步

　　在程序中使用多線程時，一般很少有多個線程能在其生命期內進行完全獨立的操作。更多的情況是一些線程進行某些處理操作，而其他的線程必須對其處理結果進行了解。正常情況下對這種處理結果的了解應當在其處理任務完成後進行。
　　如果不采取適當的措施，其他線程往往會在線程處理任務結束前就去訪問處理結果，這就很有可能得到有關處理結果的錯誤了解。例如，多個線程同時訪問同一個全局變量，如果都是讀取操作，則不會出現問題。如果一個線程負責改變此變量的值，而其他線程負責同時讀取變量內容，則不能保證讀取到的數據是經過寫線程修改後的。
　　為了確保讀線程讀取到的是經過修改的變量，就必須在向變量寫入數據時禁止其他線程對其的任何訪問，直至賦值過程結束後再解除對其他線程的訪問限製。象這種保證線程能了解其他線程任務處理結束後的處理結果而采取的保護措施即為線程同步。
　　線程的同步可分用戶模式的線程同步和內核對象的線程同步兩大類。用戶模式中線程的同步方法主要有原子訪問和臨界區等方法。其特點是同步速度特別快，適合於對線程運行速度有嚴格要求的場合。
　　內核對象的線程同步則主要由事件、等待定時器、信號量以及信號燈等內核對象構成。由於這種同步機製使用了內核對象，使用時必須將線程從用戶模式切換到內核模式，而這種轉換一般要耗費近千個CPU周期，因此同步速度較慢，但在適用性上卻要遠優於用戶模式的線程同步方式。

　　1.臨界區
　　臨界區（Critical Section）是一段獨占對某些共享資源訪問的代碼，在任意時刻隻允許一個線程對共享資源進行訪問。如果有多個線程試圖同時訪問臨界區，那麼在有一個線程進入後其他所有試圖訪問此臨界區的線程將被掛起，並一直持續到進入臨界區的線程離開。臨界區在被釋放後，其他線程可以繼續搶占，並以此達到用原子方式操作共享資源的目的。
　　臨界區在使用時以CRITICAL_SECTION結構對象保護共享資源，並分別用EnterCriticalSection（）和LeaveCriticalSection（）函數去標識和釋放一個臨界區。所用到的CRITICAL_SECTION結構對象必須經過InitializeCriticalSection（）的初始化後才能使用，而且必須確保所有線程中的任何試圖訪問此共享資源的代碼都處在此臨界區的保護之下。否則臨界區將不會起到應有的作用，共享資源依然有被破壞的可能。

CRITICAL_SECTION g_cs; // 臨界區結構對象
char g_cArray[10]; // 共享資源

UINT ThreadProc10(LPVOID pParam)
{
　EnterCriticalSection(&g_cs); 　// 進入臨界區
　for (int i = 0; i < 10; i++) // 對共享資源進行寫入操作
　{
　　g_cArray[i] = 'a';
　　Sleep(1);
　}

　LeaveCriticalSection(&g_cs); 　// 離開臨界區
　return 0;
}
UINT ThreadProc11(LPVOID pParam)
{
　
　EnterCriticalSection(&g_cs);

　for (int i = 0; i < 10; i++)
　{
　　g_cArray[10 - i - 1] = 'b';
　　Sleep(1);
　}

　LeaveCriticalSection(&g_cs);
　return 0;
}
……
void CSample08View::OnCriticalSection()
{
　InitializeCriticalSection(&g_cs);　 // 初始化臨界區
　
　AfxBeginThread(ThreadProc10, NULL); // 啟動線程
　AfxBeginThread(ThreadProc11, NULL);

　Sleep(300);

　CString sResult = CString(g_cArray);
　AfxMessageBox(sResult);
}

在使用臨界區時，一般不允許其運行時間過長，隻要進入臨界區的線程還沒有離開，其他所有試圖進入此臨界區的線程都會被掛起而進入到等待狀態，並會在一定程度上影響。程序的運行性能。尤其需要注意的是不要將等待用戶輸入或是其他一些外界幹預的操作包含到臨界區。如果進入了臨界區卻一直沒有釋放，同樣也會引起其他線程的長時間等待。換句話說，在執行了EnterCriticalSection（）語句進入臨界區後無論發生什麼，必須確保與之匹配的LeaveCriticalSection（）都能夠被執行到。可以通過添加結構化異常處理代碼來確保LeaveCriticalSection（）語句的執行。雖然臨界區同步速度很快，但卻隻能用來同步本進程內的線程，而不可用來同步多個進程中的線程。
　　MFC為臨界區提供有一個CCriticalSection類，使用該類進行線程同步處理是非常簡單的，隻需在線程函數中用CCriticalSection類成員函數Lock（）和UnLock（）標定出被保護代碼片段即可。對於上述代碼，可通過CCriticalSection類將其改寫如下：

CCriticalSection g_clsCriticalSection;　　// MFC臨界區類對象
char g_cArray[10];　　　　　　　　　　　　　 // 共享資源

UINT ThreadProc20(LPVOID pParam)
{
　g_clsCriticalSection.Lock();　　　　　 // 進入臨界區

　for (int i = 0; i < 10; i++) 　　　　　　// 對共享資源進行寫入操作
　{
　　g_cArray[i] = 'a';
　　Sleep(1);
　}
　g_clsCriticalSection.Unlock();　　　　　　// 離開臨界區
　return 0;
}
UINT ThreadProc21(LPVOID pParam)
{
　g_clsCriticalSection.Lock();

　for (int i = 0; i < 10; i++)
　{
　　g_cArray[10 - i - 1] = 'b';
　　Sleep(1);
　}

　g_clsCriticalSection.Unlock();
　return 0;
}
……
void CSample08View::OnCriticalSectionMfc()
{
　AfxBeginThread(ThreadProc20, NULL);
　AfxBeginThread(ThreadProc21, NULL);

　Sleep(300);

　CString sResult = CString(g_cArray);
　AfxMessageBox(sResult);
}

2.事件內核對象

　　在前麵講述線程通信時曾使用過事件內核對象來進行線程間的通信，除此之外，事件內核對象也可以通過通知操作的方式來保持線程的同步。對於前麵那段使用臨界區保持線程同步的代碼可用事件對象的線程同步方法改寫如下：

HANDLE hEvent = NULL; 　　　　　　　　　　　　// 事件句柄

char g_cArray[10]; 　　　　　　　　　　　　// 共享資源

UINT ThreadProc12(LPVOID pParam)
{
　WaitForSingleObject(hEvent, INFINITE);　　// 等待事件置位

　for (int i = 0; i < 10; i++)
　{
　　g_cArray[i] = 'a';
　　Sleep(1);
　}
　
　SetEvent(hEvent);　　　　　　　　　　　　　　// 處理完成後即將事件對象置位
　return 0;
}
UINT ThreadProc13(LPVOID pParam)
{
　WaitForSingleObject(hEvent, INFINITE);

　for (int i = 0; i < 10; i++)
　{
　　g_cArray[10 - i - 1] = 'b';
　　Sleep(1);
　}

　SetEvent(hEvent);
　return 0;
}
……
void CSample08View::OnEvent()
{
　hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);　　　　　// 創建事件

　SetEvent(hEvent);　　　　　　　　　　　　　　　　　　　　　 // 事件置位

　AfxBeginThread(ThreadProc12, NULL);　　　　　　　　　　　　// 啟動線程
　AfxBeginThread(ThreadProc13, NULL);

　Sleep(300);

　CString sResult = CString(g_cArray);
　AfxMessageBox(sResult);
}
在創建線程前，首先創建一個可以自動複位的事件內核對象hEvent，而線程函數則通過WaitForSingleObject（）等待函數無限等待hEvent的置位，隻有在事件置位時WaitForSingleObject（）才會返回，被保護的代碼將得以執行。對於以自動複位方式創建的事件對象，在其置位後一被WaitForSingleObject（）等待到就會立即複位，也就是說在執行ThreadProc12（）中的受保護代碼時，事件對象已經是複位狀態的，這時即使有ThreadProc13（）對CPU的搶占，也會由於WaitForSingleObject（）沒有hEvent的置位而不能繼續執行，也就沒有可能破壞受保護的共享資源。在ThreadProc12（）中的處理完成後可以通過SetEvent（）對hEvent的置位而允許ThreadProc13（）對共享資源g_cArray的處理。這裏SetEvent（）所起的作用可以看作是對某項特定任務完成的通知。
　　使用臨界區隻能同步同一進程中的線程，而使用事件內核對象則可以對進程外的線程進行同步，其前提是得到對此事件對象的訪問權。可以通過OpenEvent（）函數獲取得到，其函數原型為：

HANDLE OpenEvent(
　DWORD dwDesiredAccess, // 訪問標誌
　BOOL bInheritHandle, // 繼承標誌
　LPCTSTR lpName // 指向事件對象名的指針
);
　如果事件對象已創建（在創建事件時需要指定事件名），函數將返回指定事件的句柄。對於那些在創建事件時沒有指定事件名的事件內核對象，可以通過使用內核對象的繼承性或是調用DuplicateHandle（）函數來調用CreateEvent（）以獲得對指定事件對象的訪問權。在獲取到訪問權後所進行的同步操作與在同一個進程中所進行的線程同步操作是一樣的。
　　如果需要在一個線程中等待多個事件，則用WaitForMultipleObjects（）來等待。WaitForMultipleObjects（）與WaitForSingleObject（）類似，同時監視位於句柄數組中的所有句柄。這些被監視對象的句柄享有平等的優先權，任何一個句柄都不可能比其他句柄具有更高的優先權。WaitForMultipleObjects（）的函數原型為：
DWORD WaitForMultipleObjects(
　DWORD nCount, // 等待句柄數
　CONST HANDLE *lpHandles, // 句柄數組首地址
　BOOL fWaitAll, // 等待標誌
　DWORD dwMilliseconds // 等待時間間隔
);

參數nCount指定了要等待的內核對象的數目，存放這些內核對象的數組由lpHandles來指向。fWaitAll對指定的這nCount個內核對象的兩種等待方式進行了指定，為TRUE時當所有對象都被通知時函數才會返回，為FALSE則隻要其中任何一個得到通知就可以返回。dwMilliseconds在這裏的作用與在WaitForSingleObject（）中的作用是完全一致的。如果等待超時，函數將返回WAIT_TIMEOUT。如果返回WAIT_OBJECT_0到WAIT_OBJECT_0+nCount-1中的某個值，則說明所有指定對象的狀態均為已通知狀態（當fWaitAll為TRUE時）或是用以減去WAIT_OBJECT_0而得到發生通知的對象的索引（當fWaitAll為FALSE時）。如果返回值在WAIT_ABANDONED_0與WAIT_ABANDONED_0+nCount-1之間，則表示所有指定對象的狀態均為已通知，且其中至少有一個對象是被丟棄的互斥對象（當fWaitAll為TRUE時），或是用以減去WAIT_OBJECT_0表示一個等待正常結束的互斥對象的索引（當fWaitAll為FALSE時）。下麵給出的代碼主要展示了對WaitForMultipleObjects（）函數的使用。通過對兩個事件內核對象的等待來控製線程任務的執行與中途退出：
HANDLE hEvents[2]; 　　　　　　　　　　　　　　　　　　　　　　　　　　// 存放事件句柄的數組

UINT ThreadProc14(LPVOID pParam)
{
　DWORD dwRet1 = WaitForMultipleObjects(2, hEvents, FALSE, INFINITE);　// 等待開啟事件
　
　if (dwRet1 == WAIT_OBJECT_0)　　　　　　　　　　　　　　　　　　　　　　　// 如果開啟事件到達則線程開始執行任務
　{
　　AfxMessageBox("線程開始工作!");
　　while (true)
　　{
　　　for (int i = 0; i < 10000; i++);
　　　
　　　DWORD dwRet2 = WaitForMultipleObjects(2, hEvents, FALSE, 0);　　　// 在任務處理過程中等待結束事件
　　　
　　　if (dwRet2 == WAIT_OBJECT_0 + 1)　　　　　　　　　　　　　　　　　　　// 如果結束事件置位則立即終止任務的執行
　　　　break;
　　}
　}
　AfxMessageBox("線程退出!");
　return 0;
}
……
void CSample08View::OnStartEvent()
{
　 for (int i = 0; i < 2; i++)　　　　　　　　　　　　　　　　　　　　　　// 創建線程
　　hEvents[i] = CreateEvent(NULL, FALSE, FALSE, NULL);
　　AfxBeginThread(ThreadProc14, NULL);　　　　　　　　　　　　　　　　　 // 開啟線程
　　SetEvent(hEvents[0]);　　　　　　　　　　　　　　　　　　　　　　　　　 // 設置事件0(開啟事件)

}
void CSample08View::OnEndevent()
{
　　SetEvent(hEvents[1]);　　　　　　　　　　　　　　　　　　　　　　　　　　// 設置事件1(結束事件)

}

MFC為事件相關處理也提供了一個CEvent類，共包含有除構造函數外的4個成員函數PulseEvent（）、ResetEvent（）、SetEvent（）和UnLock（）。在功能上分別相當與Win32 API的PulseEvent（）、ResetEvent（）、SetEvent（）和CloseHandle（）等函數。而構造函數則履行了原CreateEvent（）函數創建事件對象的職責，其函數原型為：
　　CEvent(BOOL bInitiallyOwn = FALSE, BOOL bManualReset = FALSE, LPCTSTR lpszName = NULL, LPSECURITY_ATTRIBUTES lpsaAttribute = NULL );

　　3.信號量內核對象

　　信號量（Semaphore）內核對象對線程的同步方式與前麵幾種方法不同，它允許多個線程在同一時刻訪問同一資源，但是需要限製在同一時刻訪問此資源的最大線程數目。在用CreateSemaphore（）創建信號量時即要同時指出允許的最大資源計數和當前可用資源計數。一般是將當前可用資源計數設置為最大資源計數，每增加一個線程對共享資源的訪問，當前可用資源計數就會減1，隻要當前可用資源計數是大於0的，就可以發出信號量信號。但是當前可用計數減小到0時則說明當前占用資源的線程數已經達到了所允許的最大數目，不能在允許其他線程的進入，此時的信號量信號將無法發出。線程在處理完共享資源後，應在離開的同時通過ReleaseSemaphore（）函數將當前可用資源計數加1。在任何時候當前可用資源計數決不可能大於最大資源計數。
　　使用信號量內核對象進行線程同步主要會用到CreateSemaphore（）、OpenSemaphore（）、ReleaseSemaphore（）、WaitForSingleObject（）和WaitForMultipleObjects（）等函數。其中，CreateSemaphore（）用來創建一個信號量內核對象，其函數原型為：

HANDLE CreateSemaphore(
　LPSECURITY_ATTRIBUTES lpSemaphoreAttributes, // 安全屬性指針
　LONG lInitialCount, 　　　　　　　　　　　　　　// 初始計數
　LONG lMaximumCount, 　　　　　　　　　　　　　　// 最大計數
　LPCTSTR lpName 　　　　　　　　　　　　　　　　　// 對象名指針
);
參數lMaximumCount是一個有符號32位值，定義了允許的最大資源計數，最大取值不能超過4294967295。lpName參數可以為創建的信號量定義一個名字，由於其創建的是一個內核對象，因此在其他進程中可以通過該名字而得到此信號量。OpenSemaphore（）函數即可用來根據信號量名打開在其他進程中創建的信號量，函數原型如下：

HANDLE OpenSemaphore(
　DWORD dwDesiredAccess, 　　// 訪問標誌
　BOOL bInheritHandle, 　　　// 繼承標誌
　LPCTSTR lpName 　　　　　　 // 信號量名
);
在線程離開對共享資源的處理時，必須通過ReleaseSemaphore（）來增加當前可用資源計數。否則將會出現當前正在處理共享資源的實際線程數並沒有達到要限製的數值，而其他線程卻因為當前可用資源計數為0而仍無法進入的情況。ReleaseSemaphore（）的函數原型為：

BOOL ReleaseSemaphore(
　HANDLE hSemaphore, 　　 // 信號量句柄
　LONG lReleaseCount, 　　// 計數遞增數量
　LPLONG lpPreviousCount // 先前計數
);

　該函數將lReleaseCount中的值添加給信號量的當前資源計數，一般將lReleaseCount設置為1，如果需要也可以設置其他的值。WaitForSingleObject（）和WaitForMultipleObjects（）主要用在試圖進入共享資源的線程函數入口處，主要用來判斷信號量的當前可用資源計數是否允許本線程的進入。隻有在當前可用資源計數值大於0時，被監視的信號量內核對象才會得到通知。
　　信號量的使用特點使其更適用於對Socket（套接字）程序中線程的同步。例如，網絡上的HTTP服務器要對同一時間內訪問同一頁麵的用戶數加以限製，這時可以為沒一個用戶對服務器的頁麵請求設置一個線程，而頁麵則是待保護的共享資源，通過使用信號量對線程的同步作用可以確保在任一時刻無論有多少用戶對某一頁麵進行訪問，隻有不大於設定的最大用戶數目的線程能夠進行訪問，而其他的訪問企圖則被掛起，隻有在有用戶退出對此頁麵的訪問後才有可能進入。下麵給出的示例代碼即展示了類似的處理過程：
HANDLE hSemaphore;　　　　　　　　　　　　　　　　 // 信號量對象句柄

UINT ThreadProc15(LPVOID pParam)
{
　WaitForSingleObject(hSemaphore, INFINITE);　　// 試圖進入信號量關口
　
　AfxMessageBox("線程一正在執行!");　　　　　　　　// 線程任務處理
　
　ReleaseSemaphore(hSemaphore, 1, NULL);　　　　// 釋放信號量計數
　return 0;
}
UINT ThreadProc16(LPVOID pParam)
{

　WaitForSingleObject(hSemaphore, INFINITE);

　AfxMessageBox("線程二正在執行!");

　ReleaseSemaphore(hSemaphore, 1, NULL);
　return 0;
}
UINT ThreadProc17(LPVOID pParam)
{

　WaitForSingleObject(hSemaphore, INFINITE);

　AfxMessageBox("線程三正在執行!");

　ReleaseSemaphore(hSemaphore, 1, NULL);
　return 0;
}
……
void CSample08View::OnSemaphore()
{
　hSemaphore = CreateSemaphore(NULL, 2, 2, NULL);　　// 創建信號量對象

　AfxBeginThread(ThreadProc15, NULL);　　　　　　　　　// 開啟線程
　AfxBeginThread(ThreadProc16, NULL);
　AfxBeginThread(ThreadProc17, NULL);
}

　在MFC中，通過CSemaphore類對信號量作了表述。該類隻具有一個構造函數，可以構造一個信號量對象，並對初始資源計數、最大資源計數、對象名和安全屬性等進行初始化，其原型如下：

　　CSemaphore( LONG lInitialCount = 1, LONG lMaxCount = 1, LPCTSTR pstrName = NULL, LPSECURITY_ATTRIBUTES lpsaAttributes = NULL );

　　在構造了CSemaphore類對象後，任何一個訪問受保護共享資源的線程都必須通過CSemaphore從父類CSyncObject類繼承得到的Lock（）和UnLock（）成員函數來訪問或釋放CSemaphore對象。與前麵介紹的幾種通過MFC類保持線程同步的方法類似，通過CSemaphore類也可以將前麵的線程同步代碼進行改寫，這兩種使用信號量的線程同步方法無論是在實現原理上還是從實現結果上都是完全一致的。下麵給出經MFC改寫後的信號量線程同步代碼：
// MFC信號量類對象
CSemaphore g_clsSemaphore(2, 2);
UINT ThreadProc24(LPVOID pParam)
{
　// 試圖進入信號量關口
　g_clsSemaphore.Lock();
　// 線程任務處理
　AfxMessageBox("線程一正在執行!");
　// 釋放信號量計數
　g_clsSemaphore.Unlock();
　return 0;
}
UINT ThreadProc25(LPVOID pParam)
{
　// 試圖進入信號量關口
　g_clsSemaphore.Lock();
　// 線程任務處理
　AfxMessageBox("線程二正在執行!");
　// 釋放信號量計數
　g_clsSemaphore.Unlock();
　return 0;
}
UINT ThreadProc26(LPVOID pParam)
{
　// 試圖進入信號量關口
　g_clsSemaphore.Lock();
　// 線程任務處理
　AfxMessageBox("線程三正在執行!");
　// 釋放信號量計數
　g_clsSemaphore.Unlock();
　return 0;
}
……
void CSample08View::OnSemaphoreMfc()
{
　// 開啟線程
　AfxBeginThread(ThreadProc24, NULL);
　AfxBeginThread(ThreadProc25, NULL);
　AfxBeginThread(ThreadProc26, NULL);
}

4.互斥內核對象

互斥（Mutex）是一種用途非常廣泛的內核對象。能夠保證多個線程對同一共享資源的互斥訪問。同臨界區有些類似，隻有擁有互斥對象的線程才具有訪問資源的權限，由於互斥對象隻有一個，因此就決定了任何情況下此共享資源都不會同時被多個線程所訪問。當前占據資源的線程在任務處理完後應將擁有的互斥對象交出，以便其他線程在獲得後得以訪問資源。與其他幾種內核對象不同，互斥對象在操作係統中擁有特殊代碼，並由操作係統來管理，操作係統甚至還允許其進行一些其他內核對象所不能進行的非常規操作。

以互斥內核對象來保持線程同步可能用到的函數主要有CreateMutex（）、OpenMutex（）、ReleaseMutex（）、WaitForSingleObject（）和WaitForMultipleObjects（）等。在使用互斥對象前，首先要通過CreateMutex（）或OpenMutex（）創建或打開一個互斥對象。CreateMutex（）函數原型為：

HANDLE CreateMutex(
　 LPSECURITY_ATTRIBUTES lpMutexAttributes, // 安全屬性指針
　 BOOL bInitialOwner, // 初始擁有者
　 LPCTSTR lpName // 互斥對象名
);

參數bInitialOwner主要用來控製互斥對象的初始狀態。一般多將其設置為FALSE，以表明互斥對象在創建時並沒有為任何線程所占有。如果在創建互斥對象時指定了對象名，那麼可以在本進程其他地方或是在其他進程通過OpenMutex（）函數得到此互斥對象的句柄。OpenMutex（）函數原型為：

HANDLE OpenMutex(
　 DWORD dwDesiredAccess, // 訪問標誌
　 BOOL bInheritHandle, // 繼承標誌
　 LPCTSTR lpName // 互斥對象名
);

當目前對資源具有訪問權的線程不再需要訪問此資源而要離開時，必須通過ReleaseMutex（）函數來釋放其擁有的互斥對象，其函數原型為：

BOOL ReleaseMutex(HANDLE hMutex);

其唯一的參數hMutex為待釋放的互斥對象句柄。至於WaitForSingleObject（）和WaitForMultipleObjects（）等待函數在互斥對象保持線程同步中所起的作用與在其他內核對象中的作用是基本一致的，也是等待互斥內核對象的通知。但是這裏需要特別指出的是：在互斥對象通知引起調用等待函數返回時，等待函數的返回值不再是通常的WAIT_OBJECT_0（對於WaitForSingleObject（）函數）或是在WAIT_OBJECT_0到WAIT_OBJECT_0+nCount-1之間的一個值（對於WaitForMultipleObjects（）函數），而是將返回一個WAIT_ABANDONED_0（對於WaitForSingleObject（）函數）或是在WAIT_ABANDONED_0到WAIT_ABANDONED_0+nCount-1之間的一個值（對於WaitForMultipleObjects（）函數）。以此來表明線程正在等待的互斥對象由另外一個線程所擁有，而此線程卻在使用完共享資源前就已經終止。除此之外，使用互斥對象的方法在等待線程的可調度性上同使用其他幾種內核對象的方法也有所不同，其他內核對象在沒有得到通知時，受調用等待函數的作用，線程將會掛起，同時失去可調度性，而使用互斥的方法卻可以在等待的同時仍具有可調度性，這也正是互斥對象所能完成的非常規操作之一。
　　在編寫程序時，互斥對象多用在對那些為多個線程所訪問的內存塊的保護上，可以確保任何線程在處理此內存塊時都對其擁有可靠的獨占訪問權。下麵給出的示例代碼即通過互斥內核對象hMutex對共享內存快g_cArray[]進行線程的獨占訪問保護。下麵給出實現代碼清單：

// 互斥對象
HANDLE hMutex = NULL;
char g_cArray[10];
UINT ThreadProc18(LPVOID pParam)
{
　// 等待互斥對象通知
　WaitForSingleObject(hMutex, INFINITE);
　// 對共享資源進行寫入操作
　for (int i = 0; i < 10; i++)
　{
　　g_cArray[i] = 'a';
　　Sleep(1);
　}
　// 釋放互斥對象
　ReleaseMutex(hMutex);
　return 0;
}
UINT ThreadProc19(LPVOID pParam)
{
　// 等待互斥對象通知
　WaitForSingleObject(hMutex, INFINITE);
　// 對共享資源進行寫入操作
　for (int i = 0; i < 10; i++)
　{
　　g_cArray[10 - i - 1] = 'b';
　　Sleep(1);
　}
　// 釋放互斥對象
　ReleaseMutex(hMutex);
　return 0;
}
……
void CSample08View::OnMutex()
{
　// 創建互斥對象
　hMutex = CreateMutex(NULL, FALSE, NULL);
　// 啟動線程
　AfxBeginThread(ThreadProc18, NULL);
　AfxBeginThread(ThreadProc19, NULL);
　// 等待計算完畢
　Sleep(300);
　// 報告計算結果
　CString sResult = CString(g_cArray);
　AfxMessageBox(sResult);
}

互斥對象在MFC中通過CMutex類進行表述。使用CMutex類的方法非常簡單，在構造CMutex類對象的同時可以指明待查詢的互斥對象的名字，在構造函數返回後即可訪問此互斥變量。CMutex類也是隻含有構造函數這唯一的成員函數，當完成對互斥對象保護資源的訪問後，可通過調用從父類CSyncObject繼承的UnLock（）函數完成對互斥對象的釋放。CMutex類構造函數原型為：
CMutex( BOOL bInitiallyOwn = FALSE, LPCTSTR lpszName = NULL, LPSECURITY_ATTRIBUTES lpsaAttribute = NULL );

該類的適用範圍和實現原理與API方式創建的互斥內核對象是完全類似的，但要簡潔的多，下麵給出就是對前麵的示例代碼經CMutex類改寫後的程序實現清單：

CMutex g_clsMutex(FALSE, NULL); // MFC互斥類對象

UINT ThreadProc27(LPVOID pParam)
{
　g_clsMutex.Lock();　 // 等待互斥對象通知

　for (int i = 0; i < 10; i++)　 // 對共享資源進行寫入操作
　{
　　g_cArray[i] = 'a';
　　Sleep(1);
　}

　g_clsMutex.Unlock();　 // 釋放互斥對象
　return 0;
}
UINT ThreadProc28(LPVOID pParam)
{
　g_clsMutex.Lock();

　for (int i = 0; i < 10; i++)
　{
　　g_cArray[10 - i - 1] = 'b';
　　Sleep(1);
　}

　g_clsMutex.Unlock();
　return 0;
}
……
void CSample08View::OnMutexMfc()
{
　AfxBeginThread(ThreadProc27, NULL);
　AfxBeginThread(ThreadProc28, NULL);

　Sleep(300);

　CString sResult = CString(g_cArray);
　AfxMessageBox(sResult);
}

最後更新：2017-04-03 14:54:04

MFC 多線程及線程同步

上一篇： Android BadgeView使用介紹（數字提醒提示）

下一篇： tomcat報錯：The server does not support version 3.0

相關內容

熱門內容

最新內容

MFC 多線程及線程同步

上一篇： Android BadgeView使用介紹 （數字提醒提示）

下一篇： tomcat報錯：The server does not support version 3.0

相關內容

熱門內容

最新內容

上一篇： Android BadgeView使用介紹（數字提醒提示）