青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

Wood_K
See gull
posts - 3,  comments - 7,  trackbacks - 0

 
VC中多線程使用比較廣泛而且實(shí)用,在網(wǎng)上看到的教程.感覺(jué)寫的挺好.

一、問(wèn)題的提出

編寫一個(gè)耗時(shí)的單線程程序:

  新建一個(gè)基于對(duì)話框的應(yīng)用程序SingleThread,在主對(duì)話框IDD_SINGLETHREAD_DIALOG添加一個(gè)按鈕,ID為IDC_SLEEP_SIX_SECOND,標(biāo)題為“延時(shí)6秒”,添加按鈕的響應(yīng)函數(shù),代碼如下:

void CSingleThreadDlg::OnSleepSixSecond()
{
 Sleep(6000); //延時(shí)6秒
}

  編譯并運(yùn)行應(yīng)用程序,單擊“延時(shí)6秒”按鈕,你就會(huì)發(fā)現(xiàn)在這6秒期間程序就象“死機(jī)”一樣,不在響應(yīng)其它消息。為了更好地處理這種耗時(shí)的操作,我們有必要學(xué)習(xí)——多線程編程。
二、多線程概述

  進(jìn)程和線程都是操作系統(tǒng)的概念。進(jìn)程是應(yīng)用程序的執(zhí)行實(shí)例,每個(gè)進(jìn)程是由私有的虛擬地址空間、代碼、數(shù)據(jù)和其它各種系統(tǒng)資源組成,進(jìn)程在運(yùn)行過(guò)程中創(chuàng)建的資源隨著進(jìn)程的終止而被銷毀,所使用的系統(tǒng)資源在進(jìn)程終止時(shí)被釋放或關(guān)閉。
  線程是進(jìn)程內(nèi)部的一個(gè)執(zhí)行單元。系統(tǒng)創(chuàng)建好進(jìn)程后,實(shí)際上就啟動(dòng)執(zhí)行了該進(jìn)程的主執(zhí)行線程,主執(zhí)行線程以函數(shù)地址形式,比如說(shuō)main或WinMain函數(shù),將程序的啟動(dòng)點(diǎn)提供給Windows系統(tǒng)。主執(zhí)行線程終止了,進(jìn)程也就隨之終止。
  每一個(gè)進(jìn)程至少有一個(gè)主執(zhí)行線程,它無(wú)需由用戶去主動(dòng)創(chuàng)建,是由系統(tǒng)自動(dòng)創(chuàng)建的。用戶根據(jù)需要在應(yīng)用程序中創(chuàng)建其它線程,多個(gè)線程并發(fā)地運(yùn)行于同一個(gè)進(jìn)程中。一個(gè)進(jìn)程中的所有線程都在該進(jìn)程的虛擬地址空間中,共同使用這些虛擬地址空間、全局變量和系統(tǒng)資源,所以線程間的通訊非常方便,多線程技術(shù)的應(yīng)用也較為廣泛。
  多線程可以實(shí)現(xiàn)并行處理,避免了某項(xiàng)任務(wù)長(zhǎng)時(shí)間占用CPU時(shí)間。要說(shuō)明的一點(diǎn)是,目前大多數(shù)的計(jì)算機(jī)都是單處理器(CPU)的,為了運(yùn)行所有這些線程,操作系統(tǒng)為每個(gè)獨(dú)立線程安排一些CPU時(shí)間,操作系統(tǒng)以輪換方式向線程提供時(shí)間片,這就給人一種假象,好象這些線程都在同時(shí)運(yùn)行。由此可見(jiàn),如果兩個(gè)非常活躍的線程為了搶奪對(duì)CPU的控制權(quán),在線程切換時(shí)會(huì)消耗很多的CPU資源,反而會(huì)降低系統(tǒng)的性能。這一點(diǎn)在多線程編程時(shí)應(yīng)該注意。
  Win32 SDK函數(shù)支持進(jìn)行多線程的程序設(shè)計(jì),并提供了操作系統(tǒng)原理中的各種同步、互斥和臨界區(qū)等操作。Visual C++ 6.0中,使用MFC類庫(kù)也實(shí)現(xiàn)了多線程的程序設(shè)計(jì),使得多線程編程更加方便。

三、Win32 API對(duì)多線程編程的支持

  Win32 提供了一系列的API函數(shù)來(lái)完成線程的創(chuàng)建、掛起、恢復(fù)、終結(jié)以及通信等工作。下面將選取其中的一些重要函數(shù)進(jìn)行說(shuō)明。

1、HANDLE CreateThread(LPSECURITY_ATTRIBUTES lpThreadAttributes,
                 DWORD dwStackSize,
                 LPTHREAD_START_ROUTINE lpStartAddress,
                 LPVOID lpParameter,
                 DWORD dwCreationFlags,
                 LPDWORD lpThreadId);

該函數(shù)在其調(diào)用進(jìn)程的進(jìn)程空間里創(chuàng)建一個(gè)新的線程,并返回已建線程的句柄,其中各參數(shù)說(shuō)明如下:
lpThreadAttributes:指向一個(gè) SECURITY_ATTRIBUTES 結(jié)構(gòu)的指針,該結(jié)構(gòu)決定了線程的安全屬性,一般置為 NULL;
dwStackSize:指定了線程的堆棧深度,一般都設(shè)置為0;
lpStartAddress:表示新線程開始執(zhí)行時(shí)代碼所在函數(shù)的地址,即線程的起始地址。一般情況為(LPTHREAD_START_ROUTINE)ThreadFunc,ThreadFunc 是線程函數(shù)名;
lpParameter:指定了線程執(zhí)行時(shí)傳送給線程的32位參數(shù),即線程函數(shù)的參數(shù);
dwCreationFlags:控制線程創(chuàng)建的附加標(biāo)志,可以取兩種值。如果該參數(shù)為0,線程在被創(chuàng)建后就會(huì)立即開始執(zhí)行;如果該參數(shù)為CREATE_SUSPENDED,則系統(tǒng)產(chǎn)生線程后,該線程處于掛起狀態(tài),并不馬上執(zhí)行,直至函數(shù)ResumeThread被調(diào)用;
lpThreadId:該參數(shù)返回所創(chuàng)建線程的ID;
如果創(chuàng)建成功則返回線程的句柄,否則返回NULL。

2、DWORD SuspendThread(HANDLE hThread);

該函數(shù)用于掛起指定的線程,如果函數(shù)執(zhí)行成功,則線程的執(zhí)行被終止。 3、DWORD ResumeThread(HANDLE hThread);

該函數(shù)用于結(jié)束線程的掛起狀態(tài),執(zhí)行線程。 4、VOID ExitThread(DWORD dwExitCode);

該函數(shù)用于線程終結(jié)自身的執(zhí)行,主要在線程的執(zhí)行函數(shù)中被調(diào)用。其中參數(shù)dwExitCode用來(lái)設(shè)置線程的退出碼。 5、BOOL TerminateThread(HANDLE hThread,DWORD dwExitCode);

  一般情況下,線程運(yùn)行結(jié)束之后,線程函數(shù)正常返回,但是應(yīng)用程序可以調(diào)用TerminateThread強(qiáng)行終止某一線程的執(zhí)行。各參數(shù)含義如下:
hThread:將被終結(jié)的線程的句柄;
dwExitCode:用于指定線程的退出碼。
  使用TerminateThread()終止某個(gè)線程的執(zhí)行是不安全的,可能會(huì)引起系統(tǒng)不穩(wěn)定;雖然該函數(shù)立即終止線程的執(zhí)行,但并不釋放線程所占用的資源。因此,一般不建議使用該函數(shù)。

6、BOOL PostThreadMessage(DWORD idThread,
   UINT Msg,
   WPARAM wParam,
   LPARAM lParam);

該函數(shù)將一條消息放入到指定線程的消息隊(duì)列中,并且不等到消息被該線程處理時(shí)便返回。
idThread:將接收消息的線程的ID;
Msg:指定用來(lái)發(fā)送的消息;
wParam:同消息有關(guān)的字參數(shù);
lParam:同消息有關(guān)的長(zhǎng)參數(shù);
調(diào)用該函數(shù)時(shí),如果即將接收消息的線程沒(méi)有創(chuàng)建消息循環(huán),則該函數(shù)執(zhí)行失敗。

四、Win32 API多線程編程例程

例程1 MultiThread1

建立一個(gè)基于對(duì)話框的工程MultiThread1,在對(duì)話框IDD_MULTITHREAD1_DIALOG中加入兩個(gè)按鈕和一個(gè)編輯框,兩個(gè)按鈕的ID分別是IDC_START,IDC_STOP ,標(biāo)題分別為“啟動(dòng)”,“停止”,IDC_STOP的屬性選中Disabled;編輯框的ID為IDC_TIME ,屬性選中Read-only;
 
在MultiThread1Dlg.h文件中添加線程函數(shù)聲明: void ThreadFunc();

注意,線程函數(shù)的聲明應(yīng)在類CMultiThread1Dlg的外部。 在類CMultiThread1Dlg內(nèi)部添加protected型變量:  HANDLE hThread;
 DWORD ThreadID;

分別代表線程的句柄和ID。
 
在MultiThread1Dlg.cpp文件中添加全局變量m_bRun : volatile BOOL m_bRun;

m_bRun 代表線程是否正在運(yùn)行。

你要留意到全局變量 m_bRun 是使用 volatile 修飾符的,volatile 修飾符的作用是告訴編譯器無(wú)需對(duì)該變量作任何的優(yōu)化,即無(wú)需將它放到一個(gè)寄存器中,并且該值可被外部改變。對(duì)于多線程引用的全局變量來(lái)說(shuō),volatile 是一個(gè)非常重要的修飾符。

編寫線程函數(shù): void ThreadFunc()
{
 CTime time;
 CString strTime;
 m_bRun=TRUE;
 while(m_bRun)
 {
  time=CTime::GetCurrentTime();
  strTime=time.Format("%H:%M:%S");
  ::SetDlgItemText(AfxGetMainWnd()->m_hWnd,IDC_TIME,strTime);
  Sleep(1000);
 }
}

該線程函數(shù)沒(méi)有參數(shù),也不返回函數(shù)值。只要m_bRun為TRUE,線程一直運(yùn)行。

雙擊IDC_START按鈕,完成該按鈕的消息函數(shù): void CMultiThread1Dlg::OnStart()
{
 // TODO: Add your control notification handler code here
 hThread=CreateThread(NULL,
  0,
  (LPTHREAD_START_ROUTINE)ThreadFunc,
  NULL,
  0,
  &ThreadID);
 GetDlgItem(IDC_START)->EnableWindow(FALSE);
 GetDlgItem(IDC_STOP)->EnableWindow(TRUE);

}

雙擊IDC_STOP按鈕,完成該按鈕的消息函數(shù): void CMultiThread1Dlg::OnStop()
{
 // TODO: Add your control notification handler code here
 m_bRun=FALSE;
 GetDlgItem(IDC_START)->EnableWindow(TRUE);
 GetDlgItem(IDC_STOP)->EnableWindow(FALSE);
}

編譯并運(yùn)行該例程,體會(huì)使用Win32 API編寫的多線程。

 

例程2 MultiThread2

  該線程演示了如何傳送一個(gè)一個(gè)整型的參數(shù)到一個(gè)線程中,以及如何等待一個(gè)線程完成處理。

建立一個(gè)基于對(duì)話框的工程MultiThread2,在對(duì)話框IDD_MULTITHREAD2_DIALOG中加入一個(gè)編輯框和一個(gè)按鈕,ID分別是IDC_COUNT,IDC_START ,按鈕控件的標(biāo)題為“開始”;
在MultiThread2Dlg.h文件中添加線程函數(shù)聲明: void ThreadFunc(int integer);

注意,線程函數(shù)的聲明應(yīng)在類CMultiThread2Dlg的外部。

在類CMultiThread2Dlg內(nèi)部添加protected型變量:  HANDLE hThread;
 DWORD ThreadID;

分別代表線程的句柄和ID。
 
打開ClassWizard,為編輯框IDC_COUNT添加int型變量m_nCount。在MultiThread2Dlg.cpp文件中添加:void ThreadFunc(int integer)
{
 int i;
 for(i=0;i<integer;i++)
 {
  Beep(200,50);
  Sleep(1000);
 }
}

雙擊IDC_START按鈕,完成該按鈕的消息函數(shù): void CMultiThread2Dlg::OnStart()
{
 UpdateData(TRUE);
 int integer=m_nCount;
 hThread=CreateThread(NULL,
  0,
  (LPTHREAD_START_ROUTINE)ThreadFunc,
  (VOID*)integer,
  0,
  &ThreadID);
 GetDlgItem(IDC_START)->EnableWindow(FALSE);
 WaitForSingleObject(hThread,INFINITE);
 GetDlgItem(IDC_START)->EnableWindow(TRUE);
}

順便說(shuō)一下WaitForSingleObject函數(shù),其函數(shù)原型為:DWORD WaitForSingleObject(HANDLE hHandle,DWORD dwMilliseconds);

hHandle為要監(jiān)視的對(duì)象(一般為同步對(duì)象,也可以是線程)的句柄;
dwMilliseconds為hHandle對(duì)象所設(shè)置的超時(shí)值,單位為毫秒;
  當(dāng)在某一線程中調(diào)用該函數(shù)時(shí),線程暫時(shí)掛起,系統(tǒng)監(jiān)視hHandle所指向的對(duì)象的狀態(tài)。如果在掛起的dwMilliseconds毫秒內(nèi),線程所等待的對(duì)象變?yōu)橛行盘?hào)狀態(tài),則該函數(shù)立即返回;如果超時(shí)時(shí)間已經(jīng)到達(dá)dwMilliseconds毫秒,但hHandle所指向的對(duì)象還沒(méi)有變成有信號(hào)狀態(tài),函數(shù)照樣返回。參數(shù)dwMilliseconds有兩個(gè)具有特殊意義的值:0和INFINITE。若為0,則該函數(shù)立即返回;若為INFINITE,則線程一直被掛起,直到hHandle所指向的對(duì)象變?yōu)橛行盘?hào)狀態(tài)時(shí)為止。
  本例程調(diào)用該函數(shù)的作用是按下IDC_START按鈕后,一直等到線程返回,再恢復(fù)IDC_START按鈕正常狀態(tài)。編譯運(yùn)行該例程并細(xì)心體會(huì)。

例程3 MultiThread3
傳送一個(gè)結(jié)構(gòu)體給一個(gè)線程函數(shù)也是可能的,可以通過(guò)傳送一個(gè)指向結(jié)構(gòu)體的指針參數(shù)來(lái)完成。先定義一個(gè)結(jié)構(gòu)體:

typedef struct
{
 int firstArgu,
 long secondArgu,

}myType,*pMyType;

創(chuàng)建線程時(shí)CreateThread(NULL,0,threadFunc,pMyType,…);
在threadFunc函數(shù)內(nèi)部,可以使用“強(qiáng)制轉(zhuǎn)換”:

int intValue=((pMyType)lpvoid)->firstArgu;
long longValue=((pMyType)lpvoid)->seconddArgu;
……

例程3 MultiThread3將演示如何傳送一個(gè)指向結(jié)構(gòu)體的指針參數(shù)。

建立一個(gè)基于對(duì)話框的工程MultiThread3,在對(duì)話框IDD_MULTITHREAD3_DIALOG中加入一個(gè)編輯框IDC_MILLISECOND,一個(gè)按鈕IDC_START,標(biāo)題為“開始” ,一個(gè)進(jìn)度條IDC_PROGRESS1;
打開ClassWizard,為編輯框IDC_MILLISECOND添加int型變量m_nMilliSecond,為進(jìn)度條IDC_PROGRESS1添加CProgressCtrl型變量m_ctrlProgress;
在MultiThread3Dlg.h文件中添加一個(gè)結(jié)構(gòu)的定義: struct threadInfo
{
 UINT nMilliSecond;
 CProgressCtrl* pctrlProgress;
};

線程函數(shù)的聲明: UINT ThreadFunc(LPVOID lpParam);

注意,二者應(yīng)在類CMultiThread3Dlg的外部。

在類CMultiThread3Dlg內(nèi)部添加protected型變量: HANDLE hThread;
DWORD ThreadID;

分別代表線程的句柄和ID。
在MultiThread3Dlg.cpp文件中進(jìn)行如下操作:

定義公共變量 threadInfo Info;
雙擊按鈕IDC_START,添加相應(yīng)消息處理函數(shù):void CMultiThread3Dlg::OnStart()
{
 // TODO: Add your control notification handler code here

 UpdateData(TRUE);
 Info.nMilliSecond=m_nMilliSecond;
 Info.pctrlProgress=&m_ctrlProgress;

 hThread=CreateThread(NULL,
  0,
  (LPTHREAD_START_ROUTINE)ThreadFunc,
  &Info,
  0,
  &ThreadID);
/*
 GetDlgItem(IDC_START)->EnableWindow(FALSE);
 WaitForSingleObject(hThread,INFINITE);
 GetDlgItem(IDC_START)->EnableWindow(TRUE);
*/
}

在函數(shù)BOOL CMultiThread3Dlg::OnInitDialog()中添加語(yǔ)句: {
 ……
 
 // TODO: Add extra initialization here
 m_ctrlProgress.SetRange(0,99);
 m_nMilliSecond=10;
 UpdateData(FALSE);
 return TRUE;  // return TRUE  unless you set the focus to a control
}

添加線程處理函數(shù):UINT ThreadFunc(LPVOID lpParam) {
 threadInfo* pInfo=(threadInfo*)lpParam;
 for(int i=0;i<100;i++)
 {
  int nTemp=pInfo->nMilliSecond;

  pInfo->pctrlProgress->SetPos(i);

  Sleep(nTemp);
 }
 return 0;
}

  順便補(bǔ)充一點(diǎn),如果你在void CMultiThread3Dlg::OnStart() 函數(shù)中添加/* */語(yǔ)句,編譯運(yùn)行你就會(huì)發(fā)現(xiàn)進(jìn)度條不進(jìn)行刷新,主線程也停止了反應(yīng)。什么原因呢?這是因?yàn)閃aitForSingleObject函數(shù)等待子線程(ThreadFunc)結(jié)束時(shí),導(dǎo)致了線程死鎖。因?yàn)閃aitForSingleObject函數(shù)會(huì)將主線程掛起(任何消息都得不到處理),而子線程ThreadFunc正在設(shè)置進(jìn)度條,一直在等待主線程將刷新消息處理完畢返回才會(huì)檢測(cè)通知事件。這樣兩個(gè)線程都在互相等待,死鎖發(fā)生了,編程時(shí)應(yīng)注意避免。
例程4 MultiThread4
該例程測(cè)試在Windows下最多可創(chuàng)建線程的數(shù)目。


建立一個(gè)基于對(duì)話框的工程MultiThread4,在對(duì)話框IDD_MULTITHREAD4_DIALOG中加入一個(gè)按鈕IDC_TEST和一個(gè)編輯框IDC_COUNT,按鈕標(biāo)題為“測(cè)試” , 編輯框?qū)傩赃x中Read-only;
在MultiThread4Dlg.cpp文件中進(jìn)行如下操作:

添加公共變量volatile BOOL m_bRunFlag=TRUE;
該變量表示是否還能繼續(xù)創(chuàng)建線程。

添加線程函數(shù):

DWORD WINAPI threadFunc(LPVOID threadNum)
{
 while(m_bRunFlag)
 {
  Sleep(3000);
 }
 return 0;
}

只要 m_bRunFlag 變量為TRUE,線程一直運(yùn)行。

雙擊按鈕IDC_TEST,添加其響應(yīng)消息函數(shù):void CMultiThread4Dlg::OnTest()
{
 DWORD threadID;
 GetDlgItem(IDC_TEST)->EnableWindow(FALSE);
 long nCount=0;
 while(m_bRunFlag)
 {
  if(CreateThread(NULL,0,threadFunc,NULL,0,&threadID)==NULL)
  {
   m_bRunFlag=FALSE;
   break;
  }
  else
  {
   nCount++;
  }
 }
   //不斷創(chuàng)建線程,直到再不能創(chuàng)建為止
 m_nCount=nCount;
 UpdateData(FALSE);
 Sleep(5000);
   //延時(shí)5秒,等待所有創(chuàng)建的線程結(jié)束
 GetDlgItem(IDC_TEST)->EnableWindow(TRUE);
    m_bRunFlag=TRUE;
}

五、MFC對(duì)多線程編程的支持

  MFC中有兩類線程,分別稱之為工作者線程和用戶界面線程。二者的主要區(qū)別在于工作者線程沒(méi)有消息循環(huán),而用戶界面線程有自己的消息隊(duì)列和消息循環(huán)。
  工作者線程沒(méi)有消息機(jī)制,通常用來(lái)執(zhí)行后臺(tái)計(jì)算和維護(hù)任務(wù),如冗長(zhǎng)的計(jì)算過(guò)程,打印機(jī)的后臺(tái)打印等。用戶界面線程一般用于處理獨(dú)立于其他線程執(zhí)行之外的用戶輸入,響應(yīng)用戶及系統(tǒng)所產(chǎn)生的事件和消息等。但對(duì)于Win32的API編程而言,這兩種線程是沒(méi)有區(qū)別的,它們都只需線程的啟動(dòng)地址即可啟動(dòng)線程來(lái)執(zhí)行任務(wù)。
  在MFC中,一般用全局函數(shù)AfxBeginThread()來(lái)創(chuàng)建并初始化一個(gè)線程的運(yùn)行,該函數(shù)有兩種重載形式,分別用于創(chuàng)建工作者線程和用戶界面線程。兩種重載函數(shù)原型和參數(shù)分別說(shuō)明如下:

(1) CWinThread* AfxBeginThread(AFX_THREADPROC pfnThreadProc,
                      LPVOID pParam,
                      nPriority=THREAD_PRIORITY_NORMAL,
                      UINT nStackSize=0,
                      DWORD dwCreateFlags=0,
                      LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);

PfnThreadProc:指向工作者線程的執(zhí)行函數(shù)的指針,線程函數(shù)原型必須聲明如下: UINT ExecutingFunction(LPVOID pParam);

請(qǐng)注意,ExecutingFunction()應(yīng)返回一個(gè)UINT類型的值,用以指明該函數(shù)結(jié)束的原因。一般情況下,返回0表明執(zhí)行成功。
pParam:傳遞給線程函數(shù)的一個(gè)32位參數(shù),執(zhí)行函數(shù)將用某種方式解釋該值。它可以是數(shù)值,或是指向一個(gè)結(jié)構(gòu)的指針,甚至可以被忽略;
nPriority:線程的優(yōu)先級(jí)。如果為0,則線程與其父線程具有相同的優(yōu)先級(jí);
nStackSize:線程為自己分配堆棧的大小,其單位為字節(jié)。如果nStackSize被設(shè)為0,則線程的堆棧被設(shè)置成與父線程堆棧相同大小;
dwCreateFlags:如果為0,則線程在創(chuàng)建后立刻開始執(zhí)行。如果為CREATE_SUSPEND,則線程在創(chuàng)建后立刻被掛起;
lpSecurityAttrs:線程的安全屬性指針,一般為NULL;
 (2) CWinThread* AfxBeginThread(CRuntimeClass* pThreadClass,
                      int nPriority=THREAD_PRIORITY_NORMAL,
                      UINT nStackSize=0,
                      DWORD dwCreateFlags=0,
                      LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);


  pThreadClass 是指向 CWinThread 的一個(gè)導(dǎo)出類的運(yùn)行時(shí)類對(duì)象的指針,該導(dǎo)出類定義了被創(chuàng)建的用戶界面線程的啟動(dòng)、退出等;其它參數(shù)的意義同形式1。使用函數(shù)的這個(gè)原型生成的線程也有消息機(jī)制,在以后的例子中我們將發(fā)現(xiàn)同主線程的機(jī)制幾乎一樣。

下面我們對(duì)CWinThread類的數(shù)據(jù)成員及常用函數(shù)進(jìn)行簡(jiǎn)要說(shuō)明。

m_hThread:當(dāng)前線程的句柄;
m_nThreadID:當(dāng)前線程的ID;
m_pMainWnd:指向應(yīng)用程序主窗口的指針
BOOL CWinThread::CreateThread(DWORD dwCreateFlags=0,
UINT nStackSize=0,
LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);

  該函數(shù)中的dwCreateFlags、nStackSize、lpSecurityAttrs參數(shù)和API函數(shù)CreateThread中的對(duì)應(yīng)參數(shù)有相同含義,該函數(shù)執(zhí)行成功,返回非0值,否則返回0。
  一般情況下,調(diào)用AfxBeginThread()來(lái)一次性地創(chuàng)建并啟動(dòng)一個(gè)線程,但是也可以通過(guò)兩步法來(lái)創(chuàng)建線程:首先創(chuàng)建CWinThread類的一個(gè)對(duì)象,然后調(diào)用該對(duì)象的成員函數(shù)CreateThread()來(lái)啟動(dòng)該線程。

virtual BOOL CWinThread::InitInstance();

  重載該函數(shù)以控制用戶界面線程實(shí)例的初始化。初始化成功則返回非0值,否則返回0。用戶界面線程經(jīng)常重載該函數(shù),工作者線程一般不使用InitInstance()。 virtual int CWinThread::ExitInstance();

  在線程終結(jié)前重載該函數(shù)進(jìn)行一些必要的清理工作。該函數(shù)返回線程的退出碼,0表示執(zhí)行成功,非0值用來(lái)標(biāo)識(shí)各種錯(cuò)誤。同InitInstance()成員函數(shù)一樣,該函數(shù)也只適用于用戶界面線程。
六、MFC多線程編程實(shí)例

  在Visual C++ 6.0編程環(huán)境中,我們既可以編寫C風(fēng)格的32位Win32應(yīng)用程序,也可以利用MFC類庫(kù)編寫C++風(fēng)格的應(yīng)用程序,二者各有其優(yōu)缺點(diǎn)。基于Win32的應(yīng)用程序執(zhí)行代碼小巧,運(yùn)行效率高,但要求程序員編寫的代碼較多,且需要管理系統(tǒng)提供給程序的所有資源;而基于MFC類庫(kù)的應(yīng)用程序可以快速建立起應(yīng)用程序,類庫(kù)為程序員提供了大量的封裝類,而且Developer Studio為程序員提供了一些工具來(lái)管理用戶源程序,其缺點(diǎn)是類庫(kù)代碼很龐大。由于使用類庫(kù)所帶來(lái)的快速、簡(jiǎn)捷和功能強(qiáng)大等優(yōu)越性,因此除非有特殊的需要,否則Visual C++推薦使用MFC類庫(kù)進(jìn)行程序開發(fā)。

我們知道,MFC中的線程分為兩種:用戶界面線程和工作者線程。我們將分別舉例說(shuō)明。

用 MFC 類庫(kù)編程實(shí)現(xiàn)工作者線程

例程5 MultiThread5

為了與Win32 API對(duì)照,我們使用MFC 類庫(kù)編程實(shí)現(xiàn)例程3 MultiThread3。

建立一個(gè)基于對(duì)話框的工程MultiThread5,在對(duì)話框IDD_MULTITHREAD5_DIALOG中加入一個(gè)編輯框IDC_MILLISECOND,一個(gè)按鈕IDC_START,標(biāo)題為“開始” ,一個(gè)進(jìn)度條IDC_PROGRESS1;
打開ClassWizard,為編輯框IDC_MILLISECOND添加int型變量m_nMilliSecond,為進(jìn)度條IDC_PROGRESS1添加CProgressCtrl型變量m_ctrlProgress;
在MultiThread5Dlg.h文件中添加一個(gè)結(jié)構(gòu)的定義: struct threadInfo
{
 UINT nMilliSecond;
 CProgressCtrl* pctrlProgress;
};

線程函數(shù)的聲明:UINT ThreadFunc(LPVOID lpParam);
注意,二者應(yīng)在類CMultiThread5Dlg的外部。

在類CMultiThread5Dlg內(nèi)部添加protected型變量:

CWinThread* pThread;
在MultiThread5Dlg.cpp文件中進(jìn)行如下操作:定義公共變量:threadInfo Info;
雙擊按鈕IDC_START,添加相應(yīng)消息處理函數(shù):

void CMultiThread5Dlg::OnStart()
{
 // TODO: Add your control notification handler code here

 UpdateData(TRUE);
 Info.nMilliSecond=m_nMilliSecond;
 Info.pctrlProgress=&m_ctrlProgress;

 pThread=AfxBeginThread(ThreadFunc,
  &Info);
}

在函數(shù)BOOL CMultiThread3Dlg::OnInitDialog()中添加語(yǔ)句: {
 ……
 
 // TODO: Add extra initialization here
 m_ctrlProgress.SetRange(0,99);
 m_nMilliSecond=10;
 UpdateData(FALSE);
 return TRUE;  // return TRUE  unless you set the focus to a control
}

添加線程處理函數(shù): UINT ThreadFunc(LPVOID lpParam)
{
 threadInfo* pInfo=(threadInfo*)lpParam;
 for(int i=0;i<100;i++)
 {
  int nTemp=pInfo->nMilliSecond;

  pInfo->pctrlProgress->SetPos(i);

  Sleep(nTemp);
 }
 return 0;
}
用 MFC 類庫(kù)編程實(shí)現(xiàn)用戶界面線程

創(chuàng)建用戶界面線程的步驟:

使用ClassWizard創(chuàng)建類CWinThread的派生類(以CUIThread類為例) class CUIThread : public CWinThread
{
 DECLARE_DYNCREATE(CUIThread)
protected:
 CUIThread();           // protected constructor used by dynamic creation

// Attributes
public:

// Operations
public:

// Overrides
 // ClassWizard generated virtual function overrides
 //{{AFX_VIRTUAL(CUIThread)
 public:
 virtual BOOL InitInstance();
 virtual int ExitInstance();
 //}}AFX_VIRTUAL

// Implementation
protected:
 virtual ~CUIThread();

 // Generated message map functions
 //{{AFX_MSG(CUIThread)
  // NOTE - the ClassWizard will add and remove member functions here.
 //}}AFX_MSG

 DECLARE_MESSAGE_MAP()
};

重載函數(shù)InitInstance()和ExitInstance()。 BOOL CUIThread::InitInstance()
{
 CFrameWnd* wnd=new CFrameWnd;
 wnd->Create(NULL,"UI Thread Window");
 wnd->ShowWindow(SW_SHOW);
 wnd->UpdateWindow();
 m_pMainWnd=wnd;
 return TRUE;
}

創(chuàng)建新的用戶界面線程 void CUIThreadDlg::OnButton1()
{
 CUIThread* pThread=new CUIThread();
 pThread->CreateThread();
}

請(qǐng)注意以下兩點(diǎn):

A、在UIThreadDlg.cpp的開頭加入語(yǔ)句: #include "UIThread.h"
B、把UIThread.h中類CUIThread()的構(gòu)造函數(shù)的特性由 protected 改為 public。
  用戶界面線程的執(zhí)行次序與應(yīng)用程序主線程相同,首先調(diào)用用戶界面線程類的InitInstance()函數(shù),如果返回TRUE,繼續(xù)調(diào)用線程的Run()函數(shù),該函數(shù)的作用是運(yùn)行一個(gè)標(biāo)準(zhǔn)的消息循環(huán),并且當(dāng)收到WM_QUIT消息后中斷,在消息循環(huán)過(guò)程中,Run()函數(shù)檢測(cè)到線程空閑時(shí)(沒(méi)有消息),也將調(diào)用OnIdle()函數(shù),最后Run()函數(shù)返回,MFC調(diào)用ExitInstance()函數(shù)清理資源。
  你可以創(chuàng)建一個(gè)沒(méi)有界面而有消息循環(huán)的線程,例如:你可以從CWinThread派生一個(gè)新類,在InitInstance函數(shù)中完成某項(xiàng)任務(wù)并返回FALSE,這表示僅執(zhí)行InitInstance函數(shù)中的任務(wù)而不執(zhí)行消息循環(huán),你可以通過(guò)這種方法,完成一個(gè)工作者線程的功能。

例程6 MultiThread6

建立一個(gè)基于對(duì)話框的工程MultiThread6,在對(duì)話框IDD_MULTITHREAD6_DIALOG中加入一個(gè)按鈕IDC_UI_THREAD,標(biāo)題為“用戶界面線程”
右擊工程并選中“New Class…”為工程添加基類為CWinThread派生線程類CUIThread。
給工程添加新對(duì)話框IDD_UITHREADDLG,標(biāo)題為“線程對(duì)話框”。
為對(duì)話框IDD_UITHREADDLG創(chuàng)建一個(gè)基于CDialog的類CUIThreadDlg。使用ClassWizard為CUIThreadDlg類添加WM_LBUTTONDOWN消息的處理函數(shù)OnLButtonDown,如下: void CUIThreadDlg::OnLButtonDown(UINT nFlags, CPoint point)
{
 AfxMessageBox("You Clicked The Left Button!");
 CDialog::OnLButtonDown(nFlags, point);
}
在UIThread.h中添加 #include "UIThreadDlg.h"
并在CUIThread類中添加protected變量CUIThread m_dlg: class CUIThread : public CWinThread
{
 DECLARE_DYNCREATE(CUIThread)
protected:
 CUIThread();           // protected constructor used by dynamic creation

// Attributes
public:

// Operations
public:

// Overrides
 // ClassWizard generated virtual function overrides
 //{{AFX_VIRTUAL(CUIThread)
 public:
 virtual BOOL InitInstance();
 virtual int ExitInstance();
 //}}AFX_VIRTUAL

// Implementation
protected:
 CUIThreadDlg m_dlg;
 virtual ~CUIThread();

 // Generated message map functions
 //{{AFX_MSG(CUIThread)
  // NOTE - the ClassWizard will add and remove member functions here.
 //}}AFX_MSG

 DECLARE_MESSAGE_MAP()
};

分別重載InitInstance()函數(shù)和ExitInstance()函數(shù): BOOL CUIThread::InitInstance()
{
 m_dlg.Create(IDD_UITHREADDLG);
 m_dlg.ShowWindow(SW_SHOW);
 m_pMainWnd=&m_dlg;
 return TRUE;
}

int CUIThread::ExitInstance()
{
 m_dlg.DestroyWindow();
 return CWinThread::ExitInstance();
}

雙擊按鈕IDC_UI_THREAD,添加消息響應(yīng)函數(shù): void CMultiThread6Dlg::OnUiThread()
{
 CWinThread *pThread=AfxBeginThread(RUNTIME_CLASS(CUIThread));
}

并在MultiThread6Dlg.cpp的開頭添加: #include "UIThread.h"

  好了,編譯并運(yùn)行程序吧。每單擊一次“用戶界面線程”按鈕,都會(huì)彈出一個(gè)線程對(duì)話框,在任何一個(gè)線程對(duì)話框內(nèi)按下鼠標(biāo)左鍵,都會(huì)彈出一個(gè)消息框。
七、線程間通訊

  一般而言,應(yīng)用程序中的一個(gè)次要線程總是為主線程執(zhí)行特定的任務(wù),這樣,主線程和次要線程間必定有一個(gè)信息傳遞的渠道,也就是主線程和次要線程間要進(jìn)行通信。這種線程間的通信不但是難以避免的,而且在多線程編程中也是復(fù)雜和頻繁的,下面將進(jìn)行說(shuō)明。

使用全局變量進(jìn)行通信

由于屬于同一個(gè)進(jìn)程的各個(gè)線程共享操作系統(tǒng)分配該進(jìn)程的資源,故解決線程間通信最簡(jiǎn)單的一種方法是使用全局變量。對(duì)于標(biāo)準(zhǔn)類型的全局變量,我們建議使用volatile 修飾符,它告訴編譯器無(wú)需對(duì)該變量作任何的優(yōu)化,即無(wú)需將它放到一個(gè)寄存器中,并且該值可被外部改變。如果線程間所需傳遞的信息較復(fù)雜,我們可以定義一個(gè)結(jié)構(gòu),通過(guò)傳遞指向該結(jié)構(gòu)的指針進(jìn)行傳遞信息。
 
使用自定義消息

我們可以在一個(gè)線程的執(zhí)行函數(shù)中向另一個(gè)線程發(fā)送自定義的消息來(lái)達(dá)到通信的目的。一個(gè)線程向另外一個(gè)線程發(fā)送消息是通過(guò)操作系統(tǒng)實(shí)現(xiàn)的。利用Windows操作系統(tǒng)的消息驅(qū)動(dòng)機(jī)制,當(dāng)一個(gè)線程發(fā)出一條消息時(shí),操作系統(tǒng)首先接收到該消息,然后把該消息轉(zhuǎn)發(fā)給目標(biāo)線程,接收消息的線程必須已經(jīng)建立了消息循環(huán)。
例程7 MultiThread7

  該例程演示了如何使用自定義消息進(jìn)行線程間通信。首先,主線程向CCalculateThread線程發(fā)送消息WM_CALCULATE,CCalculateThread線程收到消息后進(jìn)行計(jì)算,再向主線程發(fā)送WM_DISPLAY消息,主線程收到該消息后顯示計(jì)算結(jié)果。

建立一個(gè)基于對(duì)話框的工程MultiThread7,在對(duì)話框IDD_MULTITHREAD7_DIALOG中加入三個(gè)單選按鈕IDC_RADIO1,IDC_RADIO2,IDC_RADIO3,標(biāo)題分別為1+2+3+4+......+10,1+2+3+4+......+50,1+2+3+4+......+100。加入按鈕IDC_SUM,標(biāo)題為“求和”。加入標(biāo)簽框IDC_STATUS,屬性選中“邊框”;
在MultiThread7Dlg.h中定義如下變量: protected:
 int nAddend;

代表加數(shù)的大小。

分別雙擊三個(gè)單選按鈕,添加消息響應(yīng)函數(shù):void CMultiThread7Dlg::OnRadio1()
{
 nAddend=10;
}

void CMultiThread7Dlg::OnRadio2()
{
 nAddend=50;
 
}

void CMultiThread7Dlg::OnRadio3()
{
 nAddend=100;
 
}
并在OnInitDialog函數(shù)中完成相應(yīng)的初始化工作: BOOL CMultiThread7Dlg::OnInitDialog()
{
……
 ((CButton*)GetDlgItem(IDC_RADIO1))->SetCheck(TRUE);
 nAddend=10;
……

在MultiThread7Dlg.h中添加: #include "CalculateThread.h"
#define WM_DISPLAY WM_USER+2
class CMultiThread7Dlg : public CDialog
{
// Construction
public:
 CMultiThread7Dlg(CWnd* pParent = NULL); // standard constructor
 CCalculateThread* m_pCalculateThread;
……
protected:
 int nAddend;
 LRESULT OnDisplay(WPARAM wParam,LPARAM lParam);
……

在MultiThread7Dlg.cpp中添加: BEGIN_MESSAGE_MAP(CMultiThread7Dlg, CDialog)
……
 ON_MESSAGE(WM_DISPLAY,OnDisplay)
END_MESSAGE_MAP()

LRESULT CMultiThread7Dlg::OnDisplay(WPARAM wParam,LPARAM lParam)
{
 int nTemp=(int)wParam;
 SetDlgItemInt(IDC_STATUS,nTemp,FALSE);

  return 0;

}
以上代碼使得主線程類CMultiThread7Dlg可以處理WM_DISPLAY消息,即在IDC_STATUS標(biāo)簽框中顯示計(jì)算結(jié)果。
雙擊按鈕IDC_SUM,添加消息響應(yīng)函數(shù): void CMultiThread7Dlg::OnSum()
{
 m_pCalculateThread=
  (CCalculateThread*)AfxBeginThread(RUNTIME_CLASS(CCalculateThread));

 Sleep(500);

 m_pCalculateThread->PostThreadMessage(WM_CALCULATE,nAddend,NULL);
}
OnSum()函數(shù)的作用是建立CalculateThread線程,延時(shí)給該線程發(fā)送WM_CALCULATE消息。
右擊工程并選中“New Class…”為工程添加基類為 CWinThread 派生線程類 CCalculateThread。

在文件CalculateThread.h 中添加 #define WM_CALCULATE WM_USER+1
class CCalculateThread : public CWinThread
{
……
protected:
 afx_msg LONG OnCalculate(UINT wParam,LONG lParam);
……

在文件CalculateThread.cpp中添加 LONG CCalculateThread::OnCalculate(UINT wParam,LONG lParam)
{
 int nTmpt=0;
 for(int i=0;i<=(int)wParam;i++)
 {
  nTmpt=nTmpt+i;
 }

 Sleep(500);
    ::PostMessage((HWND)(GetMainWnd()->GetSafeHwnd()),WM_DISPLAY,nTmpt,NULL);

 return 0;
}
BEGIN_MESSAGE_MAP(CCalculateThread, CWinThread)
 //{{AFX_MSG_MAP(CCalculateThread)
  // NOTE - the ClassWizard will add and remove mapping macros here.
 //}}AFX_MSG_MAP
 ON_THREAD_MESSAGE(WM_CALCULATE,OnCalculate)
//和主線程對(duì)比,注意它們的區(qū)別
END_MESSAGE_MAP()

在CalculateThread.cpp文件的開頭添加一條: #include "MultiThread7Dlg.h"

  以上代碼為 CCalculateThread 類添加了 WM_CALCULATE 消息,消息的響應(yīng)函數(shù)是 OnCalculate,其功能是根據(jù)參數(shù) wParam 的值,進(jìn)行累加,累加結(jié)果在臨時(shí)變量nTmpt中,延時(shí)0.5秒,向主線程發(fā)送WM_DISPLAY消息進(jìn)行顯示,nTmpt作為參數(shù)傳遞。
編譯并運(yùn)行該例程,體會(huì)如何在線程間傳遞消息。
八、線程的同步

  雖然多線程能給我們帶來(lái)好處,但是也有不少問(wèn)題需要解決。例如,對(duì)于像磁盤驅(qū)動(dòng)器這樣獨(dú)占性系統(tǒng)資源,由于線程可以執(zhí)行進(jìn)程的任何代碼段,且線程的運(yùn)行是由系統(tǒng)調(diào)度自動(dòng)完成的,具有一定的不確定性,因此就有可能出現(xiàn)兩個(gè)線程同時(shí)對(duì)磁盤驅(qū)動(dòng)器進(jìn)行操作,從而出現(xiàn)操作錯(cuò)誤;又例如,對(duì)于銀行系統(tǒng)的計(jì)算機(jī)來(lái)說(shuō),可能使用一個(gè)線程來(lái)更新其用戶數(shù)據(jù)庫(kù),而用另外一個(gè)線程來(lái)讀取數(shù)據(jù)庫(kù)以響應(yīng)儲(chǔ)戶的需要,極有可能讀數(shù)據(jù)庫(kù)的線程讀取的是未完全更新的數(shù)據(jù)庫(kù),因?yàn)榭赡茉谧x的時(shí)候只有一部分?jǐn)?shù)據(jù)被更新過(guò)。

  使隸屬于同一進(jìn)程的各線程協(xié)調(diào)一致地工作稱為線程的同步。MFC提供了多種同步對(duì)象,下面我們只介紹最常用的四種:

臨界區(qū)(CCriticalSection)
事件(CEvent)
互斥量(CMutex)
信號(hào)量(CSemaphore)
 
通過(guò)這些類,我們可以比較容易地做到線程同步。

A、使用 CCriticalSection 類

  當(dāng)多個(gè)線程訪問(wèn)一個(gè)獨(dú)占性共享資源時(shí),可以使用“臨界區(qū)”對(duì)象。任一時(shí)刻只有一個(gè)線程可以擁有臨界區(qū)對(duì)象,擁有臨界區(qū)的線程可以訪問(wèn)被保護(hù)起來(lái)的資源或代碼段,其他希望進(jìn)入臨界區(qū)的線程將被掛起等待,直到擁有臨界區(qū)的線程放棄臨界區(qū)時(shí)為止,這樣就保證了不會(huì)在同一時(shí)刻出現(xiàn)多個(gè)線程訪問(wèn)共享資源。

CCriticalSection類的用法非常簡(jiǎn)單,步驟如下:
 

定義CCriticalSection類的一個(gè)全局對(duì)象(以使各個(gè)線程均能訪問(wèn)),如CCriticalSection critical_section;
在訪問(wèn)需要保護(hù)的資源或代碼之前,調(diào)用CCriticalSection類的成員Lock()獲得臨界區(qū)對(duì)象: critical_section.Lock();

在線程中調(diào)用該函數(shù)來(lái)使線程獲得它所請(qǐng)求的臨界區(qū)。如果此時(shí)沒(méi)有其它線程占有臨界區(qū)對(duì)象,則調(diào)用Lock()的線程獲得臨界區(qū);否則,線程將被掛起,并放入到一個(gè)系統(tǒng)隊(duì)列中等待,直到當(dāng)前擁有臨界區(qū)的線程釋放了臨界區(qū)時(shí)為止。
訪問(wèn)臨界區(qū)完畢后,使用CCriticalSection的成員函數(shù)Unlock()來(lái)釋放臨界區(qū):critical_section.Unlock();

再通俗一點(diǎn)講,就是線程A執(zhí)行到critical_section.Lock();語(yǔ)句時(shí),如果其它線程(B)正在執(zhí)行critical_section.Lock();語(yǔ)句后且critical_section. Unlock();語(yǔ)句前的語(yǔ)句時(shí),線程A就會(huì)等待,直到線程B執(zhí)行完critical_section. Unlock();語(yǔ)句,線程A才會(huì)繼續(xù)執(zhí)行。
下面再通過(guò)一個(gè)實(shí)例進(jìn)行演示說(shuō)明。


例程8 MultiThread8

建立一個(gè)基于對(duì)話框的工程MultiThread8,在對(duì)話框IDD_MULTITHREAD8_DIALOG中加入兩個(gè)按鈕和兩個(gè)編輯框控件,兩個(gè)按鈕的ID分別為IDC_WRITEW和IDC_WRITED,標(biāo)題分別為“寫‘W’”和“寫‘D’”;兩個(gè)編輯框的ID分別為IDC_W和IDC_D,屬性都選中Read-only;
在MultiThread8Dlg.h文件中聲明兩個(gè)線程函數(shù): UINT WriteW(LPVOID pParam);
UINT WriteD(LPVOID pParam);

使用ClassWizard分別給IDC_W和IDC_D添加CEdit類變量m_ctrlW和m_ctrlD;
在MultiThread8Dlg.cpp文件中添加如下內(nèi)容:

為了文件中能夠正確使用同步類,在文件開頭添加:#include "afxmt.h"

定義臨界區(qū)和一個(gè)字符數(shù)組,為了能夠在不同線程間使用,定義為全局變量:CCriticalSection critical_section;
char g_Array[10];

添加線程函數(shù):UINT WriteW(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 critical_section.Lock();
 //鎖定臨界區(qū),其它線程遇到critical_section.Lock();語(yǔ)句時(shí)要等待
 //直至執(zhí)行critical_section.Unlock();語(yǔ)句
 for(int i=0;i<10;i++)
 {
  g_Array[i]=''W'';
     pEdit->SetWindowText(g_Array);
  Sleep(1000);
 }
 critical_section.Unlock();
 return 0;

}

UINT WriteD(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 critical_section.Lock();
 //鎖定臨界區(qū),其它線程遇到critical_section.Lock();語(yǔ)句時(shí)要等待
 //直至執(zhí)行critical_section.Unlock();語(yǔ)句
 for(int i=0;i<10;i++)
 {
  g_Array[i]=''D'';
     pEdit->SetWindowText(g_Array);
  Sleep(1000);
 }
 critical_section.Unlock();
 return 0;

}
分別雙擊按鈕IDC_WRITEW和IDC_WRITED,添加其響應(yīng)函數(shù): void CMultiThread8Dlg::OnWritew()
{
 CWinThread *pWriteW=AfxBeginThread(WriteW,
  &m_ctrlW,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteW->ResumeThread();
}

void CMultiThread8Dlg::OnWrited()
{
 CWinThread *pWriteD=AfxBeginThread(WriteD,
  &m_ctrlD,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteD->ResumeThread();
 
}
由于代碼較簡(jiǎn)單,不再詳述。編譯、運(yùn)行該例程,您可以連續(xù)點(diǎn)擊兩個(gè)按鈕,觀察體會(huì)臨界類的作用。
B、使用 CEvent 類

  CEvent 類提供了對(duì)事件的支持。事件是一個(gè)允許一個(gè)線程在某種情況發(fā)生時(shí),喚醒另外一個(gè)線程的同步對(duì)象。例如在某些網(wǎng)絡(luò)應(yīng)用程序中,一個(gè)線程(記為A)負(fù)責(zé)監(jiān)聽通訊端口,另外一個(gè)線程(記為B)負(fù)責(zé)更新用戶數(shù)據(jù)。通過(guò)使用CEvent 類,線程A可以通知線程B何時(shí)更新用戶數(shù)據(jù)。每一個(gè)CEvent 對(duì)象可以有兩種狀態(tài):有信號(hào)狀態(tài)和無(wú)信號(hào)狀態(tài)。線程監(jiān)視位于其中的CEvent 類對(duì)象的狀態(tài),并在相應(yīng)的時(shí)候采取相應(yīng)的操作。
  在MFC中,CEvent 類對(duì)象有兩種類型:人工事件和自動(dòng)事件。一個(gè)自動(dòng)CEvent 對(duì)象在被至少一個(gè)線程釋放后會(huì)自動(dòng)返回到無(wú)信號(hào)狀態(tài);而人工事件對(duì)象獲得信號(hào)后,釋放可利用線程,但直到調(diào)用成員函數(shù)ReSetEvent()才將其設(shè)置為無(wú)信號(hào)狀態(tài)。在創(chuàng)建CEvent 類的對(duì)象時(shí),默認(rèn)創(chuàng)建的是自動(dòng)事件。 CEvent 類的各成員函數(shù)的原型和參數(shù)說(shuō)明如下:

1、CEvent(BOOL bInitiallyOwn=FALSE,
          BOOL bManualReset=FALSE,
          LPCTSTR lpszName=NULL,
          LPSECURITY_ATTRIBUTES lpsaAttribute=NULL);


bInitiallyOwn:指定事件對(duì)象初始化狀態(tài),TRUE為有信號(hào),F(xiàn)ALSE為無(wú)信號(hào);
bManualReset:指定要?jiǎng)?chuàng)建的事件是屬于人工事件還是自動(dòng)事件。TRUE為人工事件,F(xiàn)ALSE為自動(dòng)事件;
后兩個(gè)參數(shù)一般設(shè)為NULL,在此不作過(guò)多說(shuō)明。
2、BOOL CEvent::SetEvent();

  將 CEvent 類對(duì)象的狀態(tài)設(shè)置為有信號(hào)狀態(tài)。如果事件是人工事件,則 CEvent 類對(duì)象保持為有信號(hào)狀態(tài),直到調(diào)用成員函數(shù)ResetEvent()將 其重新設(shè)為無(wú)信號(hào)狀態(tài)時(shí)為止。如果CEvent 類對(duì)象為自動(dòng)事件,則在SetEvent()將事件設(shè)置為有信號(hào)狀態(tài)后,CEvent 類對(duì)象由系統(tǒng)自動(dòng)重置為無(wú)信號(hào)狀態(tài)。

如果該函數(shù)執(zhí)行成功,則返回非零值,否則返回零。 3、BOOL CEvent::ResetEvent();
  該函數(shù)將事件的狀態(tài)設(shè)置為無(wú)信號(hào)狀態(tài),并保持該狀態(tài)直至SetEvent()被調(diào)用時(shí)為止。由于自動(dòng)事件是由系統(tǒng)自動(dòng)重置,故自動(dòng)事件不需要調(diào)用該函數(shù)。如果該函數(shù)執(zhí)行成功,返回非零值,否則返回零。我們一般通過(guò)調(diào)用WaitForSingleObject函數(shù)來(lái)監(jiān)視事件狀態(tài)。前面我們已經(jīng)介紹了該函數(shù)。由于語(yǔ)言描述的原因,CEvent 類的理解確實(shí)有些難度,但您只要通過(guò)仔細(xì)玩味下面例程,多看幾遍就可理解。
例程9 MultiThread9

建立一個(gè)基于對(duì)話框的工程MultiThread9,在對(duì)話框IDD_MULTITHREAD9_DIALOG中加入一個(gè)按鈕和兩個(gè)編輯框控件,按鈕的ID為IDC_WRITEW,標(biāo)題為“寫‘W’”;兩個(gè)編輯框的ID分別為IDC_W和IDC_D,屬性都選中Read-only;
在MultiThread9Dlg.h文件中聲明兩個(gè)線程函數(shù): UINT WriteW(LPVOID pParam);
UINT WriteD(LPVOID pParam);

使用ClassWizard分別給IDC_W和IDC_D添加CEdit類變量m_ctrlW和m_ctrlD;
在MultiThread9Dlg.cpp文件中添加如下內(nèi)容:
為了文件中能夠正確使用同步類,在文件開頭添加

#include "afxmt.h"

定義事件對(duì)象和一個(gè)字符數(shù)組,為了能夠在不同線程間使用,定義為全局變量。 CEvent eventWriteD;
char g_Array[10];

添加線程函數(shù): UINT WriteW(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 for(int i=0;i<10;i++)
 {
  g_Array[i]=''W'';
     pEdit->SetWindowText(g_Array);
  Sleep(1000);
 }
 eventWriteD.SetEvent();
 return 0;

}
UINT WriteD(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 WaitForSingleObject(eventWriteD.m_hObject,INFINITE);
 for(int i=0;i<10;i++)
 {
  g_Array[i]=''D'';
     pEdit->SetWindowText(g_Array);
  Sleep(1000);
 }
 return 0;

}

  仔細(xì)分析這兩個(gè)線程函數(shù), 您就會(huì)正確理解CEvent 類。線程WriteD執(zhí)行到 WaitForSingleObject(eventWriteD.m_hObject,INFINITE);處等待,直到事件eventWriteD為有信號(hào)該線程才往下執(zhí)行,因?yàn)閑ventWriteD對(duì)象是自動(dòng)事件,則當(dāng)WaitForSingleObject()返回時(shí),系統(tǒng)自動(dòng)把eventWriteD對(duì)象重置為無(wú)信號(hào)狀態(tài)。
雙擊按鈕IDC_WRITEW,添加其響應(yīng)函數(shù): void CMultiThread9Dlg::OnWritew()
{
 CWinThread *pWriteW=AfxBeginThread(WriteW,
  &m_ctrlW,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteW->ResumeThread();

 CWinThread *pWriteD=AfxBeginThread(WriteD,
  &m_ctrlD,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteD->ResumeThread();
 
}
編譯并運(yùn)行程序,單擊“寫‘W’”按鈕,體會(huì)事件對(duì)象的作用。
C、使用CMutex 類

  互斥對(duì)象與臨界區(qū)對(duì)象很像.互斥對(duì)象與臨界區(qū)對(duì)象的不同在于:互斥對(duì)象可以在進(jìn)程間使用,而臨界區(qū)對(duì)象只能在同一進(jìn)程的各線程間使用。當(dāng)然,互斥對(duì)象也可以用于同一進(jìn)程的各個(gè)線程間,但是在這種情況下,使用臨界區(qū)會(huì)更節(jié)省系統(tǒng)資源,更有效率。

D、使用CSemaphore 類

  當(dāng)需要一個(gè)計(jì)數(shù)器來(lái)限制可以使用某個(gè)線程的數(shù)目時(shí),可以使用“信號(hào)量”對(duì)象。CSemaphore 類的對(duì)象保存了對(duì)當(dāng)前訪問(wèn)某一指定資源的線程的計(jì)數(shù)值,該計(jì)數(shù)值是當(dāng)前還可以使用該資源的線程的數(shù)目。如果這個(gè)計(jì)數(shù)達(dá)到了零,則所有對(duì)這個(gè)CSemaphore 類對(duì)象所控制的資源的訪問(wèn)嘗試都被放入到一個(gè)隊(duì)列中等待,直到超時(shí)或計(jì)數(shù)值不為零時(shí)為止。一個(gè)線程被釋放已訪問(wèn)了被保護(hù)的資源時(shí),計(jì)數(shù)值減1;一個(gè)線程完成了對(duì)被控共享資源的訪問(wèn)時(shí),計(jì)數(shù)值增1。這個(gè)被CSemaphore 類對(duì)象所控制的資源可以同時(shí)接受訪問(wèn)的最大線程數(shù)在該對(duì)象的構(gòu)建函數(shù)中指定。

CSemaphore 類的構(gòu)造函數(shù)原型及參數(shù)說(shuō)明如下:

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

lInitialCount:信號(hào)量對(duì)象的初始計(jì)數(shù)值,即可訪問(wèn)線程數(shù)目的初始值;
lMaxCount:信號(hào)量對(duì)象計(jì)數(shù)值的最大值,該參數(shù)決定了同一時(shí)刻可訪問(wèn)由信號(hào)量保護(hù)的資源的線程最大數(shù)目;
后兩個(gè)參數(shù)在同一進(jìn)程中使用一般為NULL,不作過(guò)多討論;
  在用CSemaphore 類的構(gòu)造函數(shù)創(chuàng)建信號(hào)量對(duì)象時(shí)要同時(shí)指出允許的最大資源計(jì)數(shù)和當(dāng)前可用資源計(jì)數(shù)。一般是將當(dāng)前可用資源計(jì)數(shù)設(shè)置為最大資源計(jì)數(shù),每增加一個(gè)線程對(duì)共享資源的訪問(wèn),當(dāng)前可用資源計(jì)數(shù)就會(huì)減1,只要當(dāng)前可用資源計(jì)數(shù)是大于0的,就可以發(fā)出信號(hào)量信號(hào)。但是當(dāng)前可用計(jì)數(shù)減小到0時(shí),則說(shuō)明當(dāng)前占用資源的線程數(shù)已經(jīng)達(dá)到了所允許的最大數(shù)目,不能再允許其它線程的進(jìn)入,此時(shí)的信號(hào)量信號(hào)將無(wú)法發(fā)出。線程在處理完共享資源后,應(yīng)在離開的同時(shí)通過(guò)ReleaseSemaphore()函數(shù)將當(dāng)前可用資源數(shù)加1。

下面給出一個(gè)簡(jiǎn)單實(shí)例來(lái)說(shuō)明 CSemaphore 類的用法。

例程10 MultiThread10

建立一個(gè)基于對(duì)話框的工程MultiThread10,在對(duì)話框IDD_MULTITHREAD10_DIALOG中加入一個(gè)按鈕和三個(gè)編輯框控件,按鈕的ID為IDC_START,標(biāo)題為“同時(shí)寫‘A’、‘B’、‘C’”;三個(gè)編輯框的ID分別為IDC_A、IDC_B和IDC_C,屬性都選中Read-only;
在MultiThread10Dlg.h文件中聲明兩個(gè)線程函數(shù): UINT WriteA(LPVOID pParam);
UINT WriteB(LPVOID pParam);
UINT WriteC(LPVOID pParam);
使用ClassWizard分別給IDC_A、IDC_B和IDC_C添加CEdit類變量m_ctrlA、m_ctrlB和m_ctrlC;
在MultiThread10Dlg.cpp文件中添加如下內(nèi)容:
為了文件中能夠正確使用同步類,在文件開頭添加:

#include "afxmt.h"

定義信號(hào)量對(duì)象和一個(gè)字符數(shù)組,為了能夠在不同線程間使用,定義為全局變量:CSemaphore semaphoreWrite(2,2); //資源最多訪問(wèn)線程2個(gè),當(dāng)前可訪問(wèn)線程數(shù)2個(gè)
char g_Array[10];
添加三個(gè)線程函數(shù):

UINT WriteA(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 WaitForSingleObject(semaphoreWrite.m_hObject,INFINITE);
 CString str;
 for(int i=0;i<10;i++)
 {
        pEdit->GetWindowText(str);
  g_Array[i]=''A'';
  str=str+g_Array[i];
     pEdit->SetWindowText(str);
  Sleep(1000);
 }
 ReleaseSemaphore(semaphoreWrite.m_hObject,1,NULL);
 return 0;

}
UINT WriteB(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 WaitForSingleObject(semaphoreWrite.m_hObject,INFINITE);
 CString str;
 for(int i=0;i<10;i++)
 {

        pEdit->GetWindowText(str);
  g_Array[i]=''B'';
  str=str+g_Array[i];
     pEdit->SetWindowText(str);
  Sleep(1000);
 }
 ReleaseSemaphore(semaphoreWrite.m_hObject,1,NULL);
 return 0;

}
UINT WriteC(LPVOID pParam)
{
 CEdit *pEdit=(CEdit*)pParam;
 pEdit->SetWindowText("");
 WaitForSingleObject(semaphoreWrite.m_hObject,INFINITE);
 for(int i=0;i<10;i++)
 {
  g_Array[i]=''C'';
     pEdit->SetWindowText(g_Array);
  Sleep(1000);
 }
 ReleaseSemaphore(semaphoreWrite.m_hObject,1,NULL);
 return 0;

}

這三個(gè)線程函數(shù)不再多說(shuō)。在信號(hào)量對(duì)象有信號(hào)的狀態(tài)下,線程執(zhí)行到WaitForSingleObject語(yǔ)句處繼續(xù)執(zhí)行,同時(shí)可用線程數(shù)減1;若線程執(zhí)行到WaitForSingleObject語(yǔ)句時(shí)信號(hào)量對(duì)象無(wú)信號(hào),線程就在這里等待,直到信號(hào)量對(duì)象有信號(hào)線程才往下執(zhí)行。
雙擊按鈕IDC_START,添加其響應(yīng)函數(shù): void CMultiThread10Dlg::OnStart()
{
 CWinThread *pWriteA=AfxBeginThread(WriteA,
  &m_ctrlA,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteA->ResumeThread();

 CWinThread *pWriteB=AfxBeginThread(WriteB,
  &m_ctrlB,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteB->ResumeThread();

 CWinThread *pWriteC=AfxBeginThread(WriteC,
  &m_ctrlC,
  THREAD_PRIORITY_NORMAL,
  0,
  CREATE_SUSPENDED);
 pWriteC->ResumeThread();


}

好吧,多線程編程就介紹到這里,希望本文能對(duì)您有所幫助。

posted on 2009-07-03 07:54 Wood_K 閱讀(108) 評(píng)論(0)  編輯 收藏 引用

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問(wèn)   Chat2DB   管理



<2025年9月>
31123456
78910111213
14151617181920
21222324252627
2829301234
567891011

常用鏈接

留言簿(1)

隨筆檔案

文章分類

文章檔案

搜索

  •  

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            亚洲精品系列| 欧美日韩亚洲国产精品| 亚洲精品一区二区三区av| 免费成人高清| 亚洲激情精品| 日韩一区二区福利| 99av国产精品欲麻豆| 亚洲视频日本| 久久福利一区| 欧美国产日本在线| 国产精品入口福利| 亚洲第一偷拍| 一区二区欧美在线| 久久不见久久见免费视频1| 老司机免费视频一区二区| 欧美激情片在线观看| 亚洲天堂男人| 欧美a一区二区| 国产精品一区二区三区四区五区| 狠狠色香婷婷久久亚洲精品| av成人毛片| 玖玖综合伊人| 亚洲视频图片小说| 欧美肥婆在线| 狠狠色伊人亚洲综合成人| 夜夜爽99久久国产综合精品女不卡| 国产麻豆视频精品| 亚洲精品国产系列| 久久av一区二区三区漫画| 亚洲欧美日韩人成在线播放| 国产一区二区黄| 久久福利精品| 亚洲婷婷综合久久一本伊一区| 欧美一区二区三区四区在线| 最新中文字幕一区二区三区| 国产精品剧情在线亚洲| 久久久久久久国产| 欧美激情中文不卡| 午夜精品久久久久久久99水蜜桃| 激情综合色综合久久| 亚洲欧洲日韩女同| 国产一区二区看久久| 国产午夜精品一区二区三区欧美| 欧美日韩国产精品一区二区亚洲| 久久久久久九九九九| 欧美在线观看视频一区二区| 99精品国产热久久91蜜凸| 亚洲人人精品| 亚洲三级影片| 一区二区毛片| 久久人人97超碰人人澡爱香蕉| 欧美一区二区三区免费看| 一区二区三区 在线观看视频| 欧美.日韩.国产.一区.二区| 欧美在线看片| 久久精品国产精品| 欧美一区二区三区另类| 久久都是精品| 欧美成人一区二区| 亚洲午夜在线视频| 久久av二区| 欧美日韩国产综合新一区| 欧美三级特黄| 国产一二精品视频| 中文欧美日韩| 亚洲最新视频在线播放| 日韩视频国产视频| 亚洲精品五月天| 性色av一区二区三区在线观看| 午夜激情久久久| 欧美日韩中文字幕日韩欧美| 欧美日韩不卡在线| 激情成人综合| 午夜精品久久久久久久| 欧美一区在线直播| 欧美在线视频观看| 欧美高清视频一区二区| 国产精品美女久久久免费| 99天天综合性| 日韩视频中文字幕| 久久国产精彩视频| 国产精品久久久久久久久久久久| 亚洲国产精品久久久久秋霞不卡 | 久久亚洲一区| 亚洲欧美日韩国产综合精品二区| 欧美在线|欧美| 欧美日韩午夜在线视频| 亚洲视频在线一区| 欧美一区1区三区3区公司| 一本大道久久a久久精二百| 免费看亚洲片| 亚洲一区免费看| 亚洲清纯自拍| 国产精品一区免费在线观看| 欧美在线免费一级片| 亚洲一区在线观看视频 | 国产视频精品免费播放| 亚洲国产一区二区三区在线播 | 亚洲黄色毛片| 国产精品v欧美精品v日韩| 久久久一区二区三区| 极品少妇一区二区| 日韩亚洲视频| 韩日欧美一区二区三区| 亚洲一区三区视频在线观看| 亚洲电影一级黄| 亚洲理伦电影| 国产欧美在线观看一区| 欧美激情精品久久久久久| 欧美激情一区二区三区不卡| 亚洲欧美不卡| 欧美激情一二区| 欧美激情偷拍| 国产中文一区| 日韩亚洲欧美成人一区| 亚洲大胆美女视频| 性欧美办公室18xxxxhd| 日韩亚洲欧美在线观看| 欧美激情一区二区久久久| 老司机精品久久| 国产农村妇女毛片精品久久麻豆 | 亚洲视屏一区| 在线看日韩欧美| 亚洲视频一区在线观看| 亚洲经典三级| 免费观看成人鲁鲁鲁鲁鲁视频| 亚洲精品一区二区三区四区高清 | 国产乱码精品| 亚洲大片免费看| 亚洲国产毛片完整版 | 亚洲二区精品| 国产精品免费观看视频| 亚洲一区二区三区四区五区午夜 | 午夜精品理论片| 亚洲丰满在线| 免费亚洲网站| 亚洲国产精品久久久久婷婷884| 国产精品入口麻豆原神| 日韩一区二区精品| 亚洲美女网站| 欧美二区在线观看| 亚洲免费观看视频| 亚洲直播在线一区| 亚洲国产精品女人久久久| 久久久不卡网国产精品一区| 亚洲国产黄色片| 久久精品成人一区二区三区| 久久精品夜色噜噜亚洲a∨| 欧美午夜视频一区二区| 亚洲一区二区三区激情| 鲁大师成人一区二区三区| 亚洲免费成人av| 欧美日韩中文字幕精品| 欧美在线国产| 一区二区高清在线观看| 欧美激情亚洲激情| 最新国产成人在线观看| 国产亚洲精品高潮| 亚洲欧美日产图| 日韩亚洲精品电影| 亚洲欧美另类在线观看| 一区二区成人精品| 国产精品ⅴa在线观看h| 欧美久久久久久久久| 欧美在线亚洲在线| 亚洲国产精品悠悠久久琪琪| 亚洲一级特黄| 精品1区2区| 国产亚洲欧美一区二区| 欧美女人交a| 欧美视频免费| 欧美.日韩.国产.一区.二区| 欧美在线一区二区三区| 久久午夜视频| 久久精品国产视频| 久久亚洲影音av资源网| 久久久人成影片一区二区三区| 暖暖成人免费视频| 欧美黄色精品| 欧美性jizz18性欧美| 国产伦精品一区二区三区照片91 | 久久米奇亚洲| 欧美高清一区| 中文日韩电影网站| 亚洲精品日韩一| 欧美国产先锋| 99精品国产福利在线观看免费| av成人免费| 久久aⅴ国产紧身牛仔裤| 免费在线国产精品| 国产精品一区三区| 亚洲成在线观看| 亚洲一区免费在线观看| 美女视频黄a大片欧美| 亚洲国产欧美在线| 亚洲在线一区| 欧美精品午夜| 国产一区二区视频在线观看| 亚洲国产激情| 午夜免费日韩视频|