四、MFC多線程間通信
1.線程之間的通信簡(jiǎn)介
一般而言,在一個(gè)應(yīng)用程序中(即進(jìn)程),一個(gè)線程往往不是孤立存在的,常常需要和其它線程通信,以執(zhí)行特定的任務(wù)。如主線程和次線程,次線程與次線程,工作線程和用戶(hù)界面線程等。這樣,線程與線程間必定有一個(gè)信息傳遞的渠道。這種線程間的通信不但是難以避免的,而且在多線程編程中也是復(fù)雜和頻繁的。線程間的通信涉及到4個(gè)問(wèn)題:
?。?) 線程間如何傳遞信息
(2) 線程之間如何同步,以使一個(gè)線程的活動(dòng)不會(huì)破壞另一個(gè)線程的活動(dòng),以保證計(jì)算結(jié)果的正確合理
?。?) 當(dāng)線程間具有依賴(lài)關(guān)系時(shí),如何調(diào)度多個(gè)線程的處理順序
?。?) 如何避免死鎖問(wèn)題
在windows系統(tǒng)中線程間的通信一般采用四種方式:全局變量方式、消息傳遞方式、參數(shù)傳遞方式和線程同步法。下面分別作介紹。
2.全局變量方式
由于屬于同一個(gè)進(jìn)程的各個(gè)線程共享操作系統(tǒng)分配該進(jìn)程的資源,故解決線程間通信最簡(jiǎn)單的一種方法是使用全局變量。對(duì)于標(biāo)準(zhǔn)類(lèi)型的全局變量,我們建議使用volatile 修飾符,它告訴編譯器無(wú)需對(duì)該變量作任何的優(yōu)化,即無(wú)需將它放到一個(gè)寄存器中,并且該值可被外部改變。
實(shí)例演示
該實(shí)例采用全局變量來(lái)控制時(shí)間顯示線程的顯示格式,比較簡(jiǎn)單。
主要的代碼如下:
.h頭文件
//線程函數(shù)聲明
DWORD WINAPIThreadProc(LPVOIDlpParam);
protected:
HANDLE m_hThread;//線程句柄
DWORD m_nThread;//線程ID
.cpp實(shí)現(xiàn)文件
volatileBYTE m_nShowFlag = 31;//定義全局變量,用于控制顯示時(shí)間的格式。volatile 修飾符的作用是告訴編譯器無(wú)需對(duì)該變量作任何的優(yōu)化,即無(wú)需將它放到一個(gè)寄存器中。
//創(chuàng)建顯示時(shí)間的線程,參數(shù)無(wú)
m_hThread =CreateThread(NULL,0,ThreadProc,NULL,0,&m_nThread);
//線程執(zhí)行函數(shù),用于實(shí)時(shí)顯示時(shí)間,并按規(guī)定格式顯示
DWORD WINAPIThreadProc(LPVOID lpParam)
{
while(m_nShowFlag)
{
CTime time;
CString strTime,strFormat;
time=CTime::GetCurrentTime();
strFormat = “%H:%M”;
if (m_nShowFlag&2)
{//日期
strFormat = “%Y-%m-%d” + strFormat;
}
if (m_nShowFlag&4)
{//秒鐘
strFormat += “:%S”;
}
if (m_nShowFlag&8)
{//周數(shù)
strFormat += “%W”;
}
if (m_nShowFlag&16)
{//星期
strFormat += “%a”;
}
strTime=time.Format(strFormat);
?。海篠etDlgItemText(AfxGetApp()-》m_pMainWnd-》m_hWnd,IDC_STATIC_TIME,strTime);
Sleep(100);
}
return 0;
}
運(yùn)行效果:

工程源碼下載地址:
http://download.csdn.net/detail/cbnotes/4962315
注意事項(xiàng):
(1) 全局變量最好放在.CPP文件的起始處,而不要放在.h頭文件中,否則將出現(xiàn)重復(fù)鏈接的編譯錯(cuò)誤。定義全局變量時(shí)最好顯式初始化,默認(rèn)初始值為零。
?。?) 注意語(yǔ)句
?。海篠etDlgItemText(AfxGetMainWnd()-》m_hWndIDC_STATIC_TIME,strTime);在VC6.0中可以通過(guò),但在VC2008卻出錯(cuò),這是因?yàn)樵赩C2008中不支持AfxGetMainWnd()-》m_hWnd來(lái)獲取HWND,但可以采AfxGetApp()-》m_pMainWnd-》m_hWnd來(lái)獲取。所以上面的語(yǔ)句更改為:
::SetDlgItemText(AfxGetApp()-》m_pMainWnd-》m_hWnd,IDC_STATIC_TIME,strTime);
?。?) 用全局變量方式來(lái)實(shí)現(xiàn)多線程的通信比較簡(jiǎn)單實(shí)用,單注意最好不要多個(gè)線程對(duì)它進(jìn)行修改,否則將可能出錯(cuò),這將在后面會(huì)具體講解。
3.參數(shù)傳遞方式
該方式是線程通信的官方標(biāo)準(zhǔn)方法,多數(shù)情況下,主線程創(chuàng)建子線程并讓其子線程為其完成特定的任務(wù),主線程在創(chuàng)建子線程時(shí),可以通過(guò)傳給線程函數(shù)的參數(shù)和其通信,三類(lèi)創(chuàng)建線程的函數(shù)都支持參數(shù)的傳遞(哪三類(lèi)?看前面的介紹吧!)。所傳遞的參數(shù)是一個(gè)32位的指針,該指針不但可以指向簡(jiǎn)單的數(shù)據(jù),而且可以指向結(jié)構(gòu)體或類(lèi)等復(fù)雜的抽象數(shù)據(jù)類(lèi)型。
實(shí)例演示
下面將分別簡(jiǎn)單演示三類(lèi)創(chuàng)建線程時(shí)提供參數(shù)傳遞的方法。
主要的代碼如下:
.h頭文件
//線程函數(shù)聲明
DWORD WINAPI ThreadFunc1(LPVOID lpParam);//線程函數(shù)
void ThreadFunc2(void *pArg); //線程函數(shù)
UINT ThreadFunc3(LPVOID lpParam);//線程函數(shù)
//全局函數(shù)
POINT GetRandPoint();//得到隨機(jī)點(diǎn)的坐標(biāo)
//結(jié)構(gòu)體定義,用于向線程傳遞多個(gè)參數(shù)
struct threadInfo
{
HWND hWnd;//主窗口句柄
COLORREF clrPen;//畫(huà)筆顏色
};
.cpp實(shí)現(xiàn)文件
//開(kāi)始創(chuàng)建線程:創(chuàng)建個(gè)線程
void CMultThreadComm2Dlg::OnStart(void)
{
//線程:使用win32 API 創(chuàng)建:實(shí)時(shí)顯示時(shí)間
m_hThread1 = CreateThread(NULL,0,ThreadFunc1,&m_stTime.m_hWnd,0,NULL);//
//線程:使用CRT 創(chuàng)建:隨機(jī)畫(huà)線
m_info.hWnd = m_hWnd;
m_info.clrPen =RGB(255,0,0);
_beginthread(ThreadFunc2,0,&m_info);
//線程:使用MFC線程函數(shù)創(chuàng)建:顯示進(jìn)度
m_pThread = AfxBeginThread(ThreadFunc3,&m_ctrlProgress);
}
//停止/開(kāi)始
void CMultThreadComm2Dlg::OnBnClickedButton1()
{
// TODO: 在此添加控件通知處理程序代碼
CString szTitle;
GetDlgItemText(IDC_BUTTON1,szTitle);
if (szTitle == “停止”)
{//停止
g_bRun = false;
SetDlgItemText(IDC_BUTTON1,“開(kāi)始”);
}
else
{//開(kāi)始
g_bRun = true;
OnStart();
SetDlgItemText(IDC_BUTTON1,“停止”);
}
}
//線程執(zhí)行函數(shù):實(shí)時(shí)顯示當(dāng)前的時(shí)間
DWORD WINAPI ThreadFunc1(LPVOID lpParam)
{
HWND *hWnd = (HWND*)lpParam;
//CWnd *pWnd = AfxGetApp()-》m_pMainWnd;//當(dāng)沒(méi)有傳遞參數(shù)時(shí),可以用該api實(shí)現(xiàn)
CWnd *pWnd = CWnd::FromHandle(*hWnd);
char tmpbuf[128] ={‘0’};
time_t t;
while(g_bRun)
{
t = time(NULL);
strftime(tmpbuf,128,“%Y-%m-%d%a %I:%M:%S %p”,localtime(&t));
pWnd-》SetWindowText(tmpbuf);
Sleep(500);
}
return 0;
}
//線程執(zhí)行函數(shù):隨機(jī)畫(huà)線
void ThreadFunc2(void *pArg)
{
threadInfo *threadinfo= (threadInfo*)pArg;
CWnd *pWnd = CWnd::FromHandle(threadinfo-》hWnd);
CDC *pDC = pWnd-》GetDC();
CPen pen(PS_SOLID,2,threadinfo-》clrPen);
pDC-》SelectObject(&pen);
pDC-》SetROP2(R2_NOTXORPEN);
while(g_bRun)
{
POINT StartPos= GetRandPoint();
POINT EndPos = GetRandPoint();
//
CString str;
str.Format(“%d,%d : %d,%d\n”,StartPos.x,StartPos.y,EndPos.x,EndPos.y);
TRACE(str);
pDC-》MoveTo(StartPos);
pDC-》LineTo(EndPos);
Sleep(100);
pDC-》MoveTo(StartPos);
pDC-》LineTo(EndPos);
Sleep(100);
}
DeleteObject(pDC);
}
//線程執(zhí)行函數(shù):顯示進(jìn)度
UINT ThreadFunc3(LPVOIDlpParam)
{
CProgressCtrl *pProgress= (CProgressCtrl*)lpParam;
while(g_bRun)
{
pProgress-》StepIt();
Sleep(500);
}
return 0;
}
//得到隨機(jī)點(diǎn)
POINT GetRandPoint()
{
POINT Point;
Point.x = rand()%439;
Point.y = rand()%208;
return Point;
}
運(yùn)行效果:

工程源碼下載地址:
http://download.csdn.net/detail/cbnotes/4984274
注意事項(xiàng):
?。?) 注意三類(lèi)線程的創(chuàng)建方法和各自的線程函數(shù)的格式(返回類(lèi)型各不一樣)。
?。?) 注意三類(lèi)參數(shù)的傳遞:?jiǎn)蝹€(gè)參數(shù)、多參數(shù)(結(jié)構(gòu)體),復(fù)雜參數(shù)(類(lèi))。
?。?) 采用參數(shù)傳遞方式進(jìn)行線程間的通信只適用于主線程向從線程的通信。
?。?) 不知道大家看出該程序的一個(gè)BUG沒(méi)有(大家可以下載工程源碼,編譯并運(yùn)行,可以很明顯的發(fā)現(xiàn)。),就是線程二的隨機(jī)畫(huà)線線程,原意是隨機(jī)畫(huà)線并清除,但運(yùn)行發(fā)現(xiàn)第一次畫(huà)線時(shí)總是沒(méi)有被清除掉,為什么?望大家動(dòng)腦,知道的可以留言,大家一起學(xué)習(xí)和討論!
電子發(fā)燒友App















評(píng)論