</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>::WaitForSingleObject(threadend.m_hObject, 0);</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">在這種情況下，如果</FONT><FONT SIZE=3>WaitForSingleObject()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>返回值為</FONT><FONT SIZE=3>WAIT_OBJECT_0,</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>則</FONT><FONT SIZE=3>CEvent</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象處在通信狀態(tài)。否則，</FONT><FONT SIZE=3>CEvent</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象處在非通信狀態(tài)。</P>
<P ALIGN="JUSTIFY">下面的例子說(shuō)明如何使用</FONT><FONT SIZE=3>CEvent</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類在兩個(gè)線程間通信。按照以下步驟進(jìn)行：</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">1.&#9;</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>在</FONT><FONT SIZE=3>ThreadView.cpp</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>中</FONT><FONT SIZE=3>#include "ThreadView.h"</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>語(yǔ)句后面加上</FONT><FONT SIZE=3>#include "afxmt.h"</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>。</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">2.&#9;</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>在</FONT><FONT SIZE=3>ThreadView.cpp</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>中</FONT><FONT SIZE=3>volatile int threadController</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>語(yǔ)句后加上下列語(yǔ)句：</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>CEvent threadStart;</P>
<P>CEvent threadEnd;</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">刪除語(yǔ)句</FONT><FONT SIZE=3>volatile int threadController</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>。</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">3.&#9;</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>用下面的代碼更換</FONT><FONT SIZE=3>ThreadProc()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>函數(shù)。</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>UINT ThreadProc(LPVOID param)</P>
<P>{</P>
<P>    ::WaitForSingleObject(threadStart.m_hObject, INFINITE);</P>
<P>    ::MessageBox((HWND)param, "Thread activated.", "Thread", MB_OK);</P>
<P>    BOOL keepRunning = TRUE;</P>
<P>    while (keepRunning)</P>
<P>    {</P>
<P>        int result = ::WaitForSingleObject(threadEnd.m_hObject, 0);</P>
<P>        if (result == WAIT_OBJECT_0)</P>
<P>            keepRunning = FALSE;</P>
<P>    }</P>
<P>    ::PostMessage((HWND)param, WM_THREADENDED, 0, 0);</P>
<P>    return 0;</P>
<P>}</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">4.&#9;</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>用下面的語(yǔ)句替換</FONT><FONT SIZE=3>OnStartthread()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>函數(shù)中的內(nèi)容。</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>threadStart.SetEvent();</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">5.&#9;</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>用下面的語(yǔ)句替換</FONT><FONT SIZE=3>OnStopthread()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>函數(shù)中的內(nèi)容。</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>threadEnd.SetEvent();</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">6.&#9;</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>使用</FONT><FONT SIZE=3>ClassWizard</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>為</FONT><FONT SIZE=3>CthreadView</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>處理</FONT><FONT SIZE=3>WM_CREATE</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>消息的函數(shù)</FONT><FONT SIZE=3>OnCreate()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，并在</FONT><FONT SIZE=3>TODO</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>后面添加代碼。</FONT><FONT SIZE=3>OnCreate()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>函數(shù)如下所示：</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>int CThreadView::OnCreate(LPCREATESTRUCT lpCreateStruct) </P>
<P>{</P>
<P>&#9;if (CView::OnCreate(lpCreateStruct) == -1)</P>
<P>&#9;&#9;return -1;</P>
<P>&#9;</P>
<P>&#9;// TODO: Add your specialized creation code here</P>
<P>&#9;HWND hWnd = GetSafeHwnd();</P>
<P>    AfxBeginThread(ThreadProc, hWnd);</P>
<P>&#9;return 0;</P>
<P>}</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">編譯并運(yùn)行這個(gè)程序，新版本的程序運(yùn)行起來(lái)和舊版本的程序一樣，但是，新版本的程序?yàn)榱藢?shí)現(xiàn)在主線程和次要線程間通信，既使用了</FONT><FONT SIZE=3>CEvent</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類，又使用了用戶定義的</FONT><FONT SIZE=3>Windows</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>消息。</P>
<P ALIGN="JUSTIFY">新版本的程序和舊版本的程序的一個(gè)大的不同在于次要線程在</FONT><FONT SIZE=3>OnCreate()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>函數(shù)中被啟動(dòng)。然而由于線程函數(shù)的第一行即調(diào)用</FONT><FONT SIZE=3>WaitForSingleObject()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，所以此線程立即被掛起并且等待</FONT><FONT SIZE=3>threadStart</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>處于通信狀態(tài)。</P>
<P ALIGN="JUSTIFY">當(dāng)</FONT><FONT SIZE=3>threadStart</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>處在通信狀態(tài)時(shí)，新線程顯示消息框，然后進(jìn)入</FONT><FONT SIZE=3>while</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>循環(huán)。這個(gè)</FONT><FONT SIZE=3>while</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>循環(huán)繼續(xù)執(zhí)行直到</FONT><FONT SIZE=3>threadEnd</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>處在通信狀態(tài)，然后線程向主線程發(fā)送一個(gè)</FONT><FONT SIZE=3>WM_THREADENDED</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>消息并退出。因?yàn)榇司€程是在</FONT><FONT SIZE=3>OnCreate()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>函數(shù)中被創(chuàng)建的</FONT><FONT SIZE=3>,</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>一旦結(jié)束，不會(huì)被重新啟動(dòng)。</P>
<P ALIGN="JUSTIFY">　</P>
</FONT><FONT FACE="仿宋_GB2312" LANG="ZH-CN" SIZE=4><P ALIGN="CENTER"><A NAME="_Toc425699149">第三節(jié)</FONT><FONT SIZE=4> </FONT><FONT FACE="仿宋_GB2312" LANG="ZH-CN" SIZE=4>線程同步</A></P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">使用多線程可以帶來(lái)一些非常有趣的問(wèn)題。例如，如何防止兩個(gè)線程在同一時(shí)間訪問(wèn)同一數(shù)據(jù)？例如，假設(shè)一個(gè)線程正在更新一個(gè)數(shù)據(jù)集，而同時(shí)另外一個(gè)線程正在讀取數(shù)據(jù)集，結(jié)果如何？第二個(gè)線程將會(huì)讀取到錯(cuò)誤的數(shù)據(jù)，因?yàn)閿?shù)據(jù)集中只有一部分元素被更新過(guò)。</P>
<P ALIGN="JUSTIFY">保持在同一個(gè)進(jìn)程內(nèi)的線程工作協(xié)調(diào)一致稱之為線程同步。</FONT><FONT SIZE=3>Event</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象實(shí)際上就是線程同步的一種形式。在本節(jié)中，你將會(huì)學(xué)到三種使你的多線程程序更安全的線程同步對(duì)象</FONT><FONT SIZE=3>—critical section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>、互斥對(duì)象（</FONT><FONT SIZE=3>mutex</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>）、信號(hào)量（</FONT><FONT SIZE=3>semaphore</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>）。</P><DIR>

</FONT><FONT FACE="Arial" SIZE=3><P>(1)&#9;</FONT><FONT FACE="黑體" LANG="ZH-CN" SIZE=3>使用</FONT><FONT FACE="Arial" SIZE=3>Critical Section</P></DIR>

</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>是一種保證在一個(gè)時(shí)間只有一個(gè)線程訪問(wèn)數(shù)據(jù)集的非常簡(jiǎn)單的方法。當(dāng)你使用</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，你給了線程一個(gè)它們必須共享的對(duì)象。任何擁有</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象的線程可以訪問(wèn)被保護(hù)起來(lái)的數(shù)據(jù)。其它線程必須等待直到第一個(gè)線程釋放了</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象，此后其它線程可以按照順序搶占</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象，訪問(wèn)數(shù)據(jù)。</P>
<P ALIGN="JUSTIFY">因?yàn)榫€程只有擁有</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象才能訪問(wèn)數(shù)據(jù)，而且在一個(gè)時(shí)刻只有一個(gè)線程可以擁有</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象，所以決不會(huì)出現(xiàn)一個(gè)時(shí)刻有多個(gè)線程訪問(wèn)數(shù)據(jù)。</P>
<P ALIGN="JUSTIFY">為了在</FONT><FONT SIZE=3>MFC</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>程序中創(chuàng)建一個(gè)</FONT><FONT SIZE=3>Critical Section</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>對(duì)象，你應(yīng)當(dāng)創(chuàng)建</FONT><FONT SIZE=3>CcriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的對(duì)象，如下所示：</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>CCriticalSection criticalSection</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">然后，當(dāng)程序代碼準(zhǔn)備訪問(wèn)你保護(hù)的數(shù)據(jù)時(shí)，你應(yīng)當(dāng)調(diào)用</FONT><FONT SIZE=3>CCriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>的成員函數(shù)</FONT><FONT SIZE=3>Lock()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>criticalSection.Lock();</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">如果另外一個(gè)線程并沒(méi)有擁有</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，</FONT><FONT SIZE=3>Lock()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>將</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>給調(diào)用它的線程。這個(gè)線程便能夠訪問(wèn)受保護(hù)的數(shù)據(jù)，此后它調(diào)用</FONT><FONT SIZE=3>CcriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>的成員函數(shù)</FONT><FONT SIZE=3>Unlock()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>：</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>criticalSection.Unlock();</P>
</FONT><FONT SIZE=3><P ALIGN="JUSTIFY">Unlock()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>釋放了對(duì)</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>的擁有權(quán)，這樣其它線程就可以占有它并訪問(wèn)受保護(hù)的數(shù)據(jù)。</P>
<P ALIGN="JUSTIFY">最好的方法是將數(shù)據(jù)放在線程安全類中。當(dāng)你這樣做后，你不用擔(dān)心在主線程中的線程同步，線程安全類會(huì)替你處理的。下面的類</FONT><FONT SIZE=3>CCountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>便是一個(gè)線程安全類。</P>
<P ALIGN="JUSTIFY">以下是</FONT><FONT SIZE=3>COUNTARRAY.H</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，</FONT><FONT SIZE=3>CcountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>的頭文件。</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>#include "afxmt.h"</P>
<P>class CCountArray</P>
<P>{</P>
<P>private:</P>
<P>    int array[10];</P>
<P>    CCriticalSection criticalSection;</P>
<P>public:</P>
<P>    CCountArray() {};</P>
<P>    ~CCountArray() {};</P>
<P>    void SetArray(int value);</P>
<P>    void GetArray(int dstArray[10]);</P>
<P>};</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3><P ALIGN="JUSTIFY">在該頭文件中包含一個(gè)</FONT><FONT SIZE=3>MFC</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>的頭文件</FONT><FONT SIZE=3>afxmt.h</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，以使程序可以使用</FONT><FONT SIZE=3>CCriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類。在</FONT><FONT SIZE=3>CCountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的聲明中，頭文件聲明了一個(gè)十個(gè)元素的整形數(shù)組，這是</FONT><FONT SIZE=3>CCriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的對(duì)象將要保護(hù)的數(shù)據(jù)，并且聲明了一個(gè)</FONT><FONT SIZE=3>CCriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的對(duì)象</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>。</FONT><FONT SIZE=3>CCountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的公共成員函數(shù)包含構(gòu)造和析購(gòu)函數(shù)。后面兩個(gè)成員函數(shù)用于訪問(wèn)數(shù)據(jù)。</P>
<P ALIGN="JUSTIFY">下面是</FONT><FONT SIZE=3>CCountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的執(zhí)行文件。注意，在每一個(gè)成員函數(shù)中，</FONT><FONT SIZE=3>CCountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>都在密切關(guān)注著</FONT><FONT SIZE=3>CCriticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的對(duì)象的狀態(tài)。這也意味這任何調(diào)用這些成員函數(shù)的線程不必?fù)?dān)心線程同步。例如，如果線程</FONT><FONT SIZE=3>1</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>調(diào)用了</FONT><FONT SIZE=3>SetArray(),SetArray()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>所做的第一件事就是調(diào)用</FONT><FONT SIZE=3>criticalSection.Lock(),</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>這將把</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>給線程</FONT><FONT SIZE=3>1</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，此后可以完成一個(gè)循環(huán)而不用擔(dān)心被其它線程打斷。如果線程</FONT><FONT SIZE=3>2</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>調(diào)用了</FONT><FONT SIZE=3>SetArray()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>或</FONT><FONT SIZE=3>GetArray(),criticalSection.Lock()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>語(yǔ)句將掛起線程</FONT><FONT SIZE=3>2</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>直到線程</FONT><FONT SIZE=3>1</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>完成循環(huán)，執(zhí)行</FONT><FONT SIZE=3>criticalSection.Unlock()</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>語(yǔ)句將對(duì)</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>的擁有權(quán)釋放。這時(shí)系統(tǒng)喚醒線程</FONT><FONT SIZE=3>2</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，并將</FONT><FONT SIZE=3>criticalSection</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>給它。通過(guò)這種方式，所有線程必須安靜的等待它們?cè)L問(wèn)數(shù)據(jù)的機(jī)會(huì)到來(lái)。</P>
<P ALIGN="JUSTIFY">下面是</FONT><FONT SIZE=3>COUNTARRAY.CPP</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>，</FONT><FONT SIZE=3>CcountArray</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=3>類的執(zhí)行文件。</P>
</FONT><FONT FACE="宋體" LANG="ZH-CN" SIZE=1><P>#include "stdafx.h"</P>
<P>#include "CountArray.h"</P>

<P>void CCountArray::SetArray(int value)</P>
<P>{</P>
<P>    criticalSection.Lock();</P>
<P>    for (int x=0; x&lt;10; ++x)</P>
<P>        array[x] = value;</P>
<P>    criticalSection.Unlock();</P>
<P>}</P>

<P>void CCountArray::GetArray(int dstArray[10])</P>