電子發(fā)燒友App
4．消息傳遞方式
在Windows程序設(shè)計(jì)中，應(yīng)用程序的每一個(gè)線程都擁有自己的消息隊(duì)列，甚至工作線程也不例外，這樣一來(lái)，就使得線程之間利用消息來(lái)傳遞信息就變的非常簡(jiǎ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)。該方式可以實(shí)現(xiàn)任意線程間的通信，所以是比較常見(jiàn)和通用的方式。
系統(tǒng)也提供了線程間發(fā)送消息的專用函數(shù)：PostThreadMessage（）。用戶先定義一個(gè)用戶消息，在一個(gè)線程調(diào)用PostThreadMessage（）函數(shù)，在消息接收線程響應(yīng)該消息，大體和常用的小子響應(yīng)處理差不多。只是消息映射為ON_THREAD_MESSAGE而不是ON_MESSAGE
如果線程有窗體，還可以使用通用的消息發(fā)送函數(shù)PostMessage（）和SendMessage（）這兩個(gè)函數(shù)。注意這兩則的區(qū)別，PostMessage（）是異步函數(shù)，調(diào)用后函數(shù)立即返回，而SendMessage（）是同步函數(shù)，要等相應(yīng)的消息響應(yīng)完成后才返回。
關(guān)于PostThreadMessage（）、PostMessage（）和SendMessage（）函數(shù)介紹請(qǐng)參考MSDN，在此就不多吃一舉了。
對(duì)于PostThreadMessage（）的用法：
先定義一個(gè)用戶消息，如：
#define WM_THREADMSG WMUSER+100
在需要發(fā)送消息的線程調(diào)用PostThreadMessage（）函數(shù)，如：
：：PostThreadMessage（idThread，WM_THREADMSG，parm1， parm2）;
或者
m_pThread-》PostThreadMessage（WM_THREADMSG，parm1， parm2）;
其中： idThread為消息接受線程的ID，parm1， parm2為要傳遞的參數(shù)，m_pThread消息接受線程指針。
在接受消息線程中（或消息處理線程中），先定義消息響應(yīng)函數(shù)，如：
afx_msg void OnThreadMessage（WPARAM wParam，LPARAM lParam）;
然后在消息映射表中添加該消息的映射，如：
ON_THREAD_MESSAGE（WM_THREADMSG，OnThreadMessage）
最后，實(shí)現(xiàn)該消息函數(shù)，如：
//顯示消息處理函數(shù)
void XXXXThread：：OnThreadMessage（WPARAM wParam，LPARAM lParam）
{
;//消息處理
}
/////////////////////////////////////////////////////////////////////////////////
對(duì)于PostMessage（）/SendMessage（）的用法：和上面的差不多，略有不同。
首先也是先定義一個(gè)用戶消息，如：
#define WM_THREADMSG WMUSER+100
在需要發(fā)送消息的線程調(diào)用PostMessage（）/SendMessage（）函數(shù)，如：
：：PostMessage（hWnd， WM_THREADMSG， parm1， parm2）;//發(fā)送消息
或者
PWnd-》PostMessage（WM_THREADMSG， parm1， parm2）;
或者
：：SendMessage（hWnd， WM_THREADMSG， parm1， parm2）;//發(fā)送消息
或者
PWnd-》SendMessage（WM_THREADMSG， parm1， parm2）;
其中： hWnd為接受消息的窗口句柄，parm1， parm2為要傳遞的參數(shù)，pWnd消息接受窗口指針。
在接受消息線程中（或消息處理線程中），先定義消息響應(yīng)函數(shù)，如：
afx_msg LRESULT OnMyMessage（WPARAM wParam，LPARAM lParam）;
然后在消息映射表中添加該消息的映射，如：
ON_MESSAGE（WM_THREADMSG， OnMyMessage）
最后，實(shí)現(xiàn)該消息函數(shù)，如：
//消息處理函數(shù)
LRESULT XXXXWnd：：OnMyMessage（WPARAM wParam，LPARAM lParam）
{
;//消息處理
return 0;
}
實(shí)例演示
該實(shí)例主要時(shí)計(jì)算正整數(shù)1-N的累加，并采用單獨(dú)的線程來(lái)計(jì)算累積，并創(chuàng)建另一個(gè)用戶界面線程來(lái)實(shí)時(shí)顯示累加的進(jìn)度，其中涉及到一些線程間的通信，該實(shí)例主要采用了消息的方式，并結(jié)合前面已經(jīng)介紹的兩種通信方式，比較具有演示和學(xué)習(xí)的價(jià)值。
主要源碼：
主線程頭文件：
DWORD WINAPI ThreadFunc（LPVOIDlpParam）;//線程函數(shù)
protected：
HANDLE m_hThread;//線程句柄
CProgressThread *m_pThread;//用戶界面線程句柄
DWORD m_nThreadID;//線程ID號(hào)
主線程實(shí)現(xiàn)文件：
//開(kāi)始計(jì)算
void CMultThreadComm3Dlg：：OnBnClickedButton1（）
{
// TODO： 在此添加控件通知處理程序代碼
UpdateData（TRUE）;//更新數(shù)據(jù)
g_bStop = false; //重置
m_hThread = CreateThread（NULL，0，ThreadFunc，&m_nRange，0，NULL）;//創(chuàng)建計(jì)算線程
GetDlgItem（IDC_BUTTON1）-》EnableWindow（FALSE）;//防止重復(fù)計(jì)算
SetDlgItemText（IDC_STATIC_RESULT，“計(jì)算中。。。”）;
}
//結(jié)果顯示：兩種結(jié)果：，正常，，被中途中止
LRESULT CMultThreadComm3Dlg：：OnResult（WPARAMwParam，LPARAMlParam）
{
if （wParam == 1）
{//被中途中止
SetDlgItemText（IDC_STATIC_RESULT，“被中止啦！”）;
}
else
{//正常結(jié)束
SetDlgItemInt（IDC_STATIC_RESULT，lParam）;
}
GetDlgItem（IDC_BUTTON1）-》EnableWindow（TRUE）;//使能下次計(jì)算按鈕
CloseHandle（m_hThread）;//關(guān)閉線程句柄，注意一定要關(guān)閉它
return 0;
}
//線程執(zhí)行函數(shù)：計(jì)算
DWORD WINAPI ThreadFunc（LPVOIDlpParam）
{
UINT *pRange =（UINT*）lpParam;//得到參數(shù)值
long nResult= 0L;//計(jì)算結(jié)果值
bool bStop = false;//標(biāo)識(shí)是否中途被中止
CProgressThread *m_pThread= （CProgressThread*）AfxBeginThread（RUNTIME_CLASS（CProgressThread））;//創(chuàng)建顯示進(jìn)程
m_pThread-》PostThreadMessage（WM_PROGRESS，0，*pRange）;//傳遞參數(shù)，進(jìn)度條的范圍
for（int i=0;i《=*pRange;i++）//開(kāi)始計(jì)算
{
if （g_bStop）
{//中途取消了
bStop = true;
break;//退出循環(huán)
}
nResult += i;
m_pThread-》PostThreadMessage（WM_PROGRESS，1，i）;//進(jìn)度
Sleep（10）;//為了演示效果，特意延時(shí)
}
//完成
：：PostMessage（AfxGetApp（）-》m_pMainWnd-》m_hWnd，WM_RESULT，bStop，nResult）;//顯示結(jié)果
m_pThread-》PostThreadMessage（WM_PROGRESS，2，0）;//結(jié)束進(jìn)度
return 0;
}
累加線程頭文件：
CProgressDlg *m_pProgressDlg;//進(jìn)度條對(duì)話框
unsigned int m_nRange;//進(jìn)度條的范圍
累加線程實(shí)現(xiàn)文件：
BOOL CProgressThread：：InitInstance（）
{
// TODO： 在此執(zhí)行任意逐線程初始化
//創(chuàng)建非模式進(jìn)度顯示對(duì)話框
m_pProgressDlg = newCProgressDlg（）;
m_pProgressDlg-》Create（IDD_DIALOG1）;
m_pProgressDlg-》ShowWindow（SW_SHOW）;
return TRUE;
}
BEGIN_MESSAGE_MAP（CProgressThread， CWinThread）
ON_THREAD_MESSAGE（WM_PROGRESS， &CProgressThread：：OnThreadMsg）
END_MESSAGE_MAP（）
// CProgressThread 消息處理程序
//線程消息處理函數(shù)
void CProgressThread：：OnThreadMsg（WPARAM wParam，LPARAM lParam）
{
if （wParam == 0）
{//初始化進(jìn)度條
m_nRange = lParam;
m_pProgressDlg-》m_ProgressCtrl.SetRange（0，lParam）;
}
else if （wParam == 1）
{//顯示進(jìn)度
m_pProgressDlg-》m_ProgressCtrl.SetPos（lParam）;//顯示進(jìn)度
CString str;
str.Format（“%d%%”，int（（float）lParam/m_nRange*100））;
m_pProgressDlg-》m_stValue.SetWindowText（str）;//顯示百分?jǐn)?shù)
str.Format（“計(jì)算處理中，請(qǐng)稍等。。。 %d/%d cbNotes”，lParam，m_nRange）;//顯示實(shí)時(shí)的當(dāng)前操作
m_pProgressDlg-》SetWindowText（str）;
}
else
{//完成，退出進(jìn)度條
m_pProgressDlg-》CloseDlg（）;//結(jié)束進(jìn)程對(duì)話框
AfxEndThread（0）;//終止本線程，也可以使用PostQuitMessage（0）;
}
}
進(jìn)度條對(duì)話框類
//系統(tǒng)消息處理
void CProgressDlg：：OnSysCommand（UINT nID， LPARAM lParam）
{
// TODO： 在此添加消息處理程序代碼和/或調(diào)用默認(rèn)值
if （nID == SC_CLOSE）//關(guān)閉
{//攔截關(guān)閉按鈕消息
if （AfxMessageBox（“確定要【終止】本次計(jì)算嗎？”，MB_YESNO|MB_APPLMODAL|MB_ICONQUESTION|MB_DEFBUTTON2）==IDYES）
{
g_bStop = true;//中途取消操作，結(jié)束計(jì)算線程。
}
return;
}
CDialog：：OnSysCommand（nID， lParam）;
}
//關(guān)閉窗口
void CProgressDlg：：CloseDlg（void）
{
OnCancel（）;
}
//重載OnCancel（）：注意非模式對(duì)話框的退出
void CProgressDlg：：OnCancel（）
{
// TODO： 在此添加專用代碼和/或調(diào)用基類
DestroyWindow（）;//
//CDialog：：OnCancel（）;
}
void CProgressDlg：：PostNcDestroy（）
{
// TODO： 在此添加專用代碼和/或調(diào)用基類
CDialog：：PostNcDestroy（）;
delete this;
}
運(yùn)行結(jié)果：
工程源碼下載地址：
http://download.csdn.net/detail/cbnotes/5007011
注意事項(xiàng)：
（1） 注意線程消息的映射方式：
ON_THREAD_MESSAGE（WM_PROGRESS， &CProgressThread：：OnThreadMsg）
和一般的窗口消息映射不同，不要搞錯(cuò)了。
（2） 注意用戶界面線程的退出，計(jì)算完后要記得結(jié)束該線程，有專門(mén)的函數(shù)：
AfxEndThread（0），也可以使用PostQuitMessage（0）。這兩種方式都是比較安全的。不推薦強(qiáng)制中止線程，否則會(huì)出現(xiàn)意想不到的問(wèn)題。
（3） 該實(shí)例還實(shí)現(xiàn)了執(zhí)行過(guò)程按退出按鈕時(shí)的處理方法，采用了全局變量的
方式來(lái)控制計(jì)算線程的中途退出，我自認(rèn)為是一種比較好的控制方式。我開(kāi)始采用強(qiáng)制中止的方式會(huì)出現(xiàn)消息延后的現(xiàn)象（就是在退出按鈕的處理函數(shù)里向主線程發(fā)送消息postmessage），一直沒(méi)有找到原因，有興趣的朋友可以試試其它的退出方式供大家討論學(xué)習(xí)。
（4） 注意非模式對(duì)話框退出的處理方法，和模式對(duì)話框的退出不一樣的。
（5）用CreateThread（）函數(shù)創(chuàng)建線程將返回一個(gè)線程句柄，通過(guò)該句柄你可以控制和操作該線程，當(dāng)你不用時(shí)可以一創(chuàng)建該線程后就關(guān)閉該句柄，有專門(mén)的函數(shù)CloseHandle（）。關(guān)閉句柄并代表關(guān)閉線程，只是你不能在外部控制該線程（比如，提前結(jié)束，更改優(yōu)先級(jí)等）。在線程結(jié)束后，系統(tǒng)將自動(dòng)清理線程資源，但并不自動(dòng)關(guān)閉該句柄，所以線程結(jié)束后要記得關(guān)閉該句柄，你可能要問(wèn)為什么你這么強(qiáng)調(diào)要關(guān)閉該句柄，是因?yàn)樵摼浔℉ANDLE）是內(nèi)核對(duì)象，內(nèi)核對(duì)象的管理是操作系統(tǒng)管理的，具體你可以查查相關(guān)資料，我在此就不啰嗦了。
5．線程同步法
還可以通過(guò)線程同步來(lái)實(shí)現(xiàn)線程間通信。例如有兩個(gè)線程，線程A寫(xiě)入數(shù)據(jù)，線程B讀出線程A準(zhǔn)備好的數(shù)據(jù)并進(jìn)行一些操作。這種情況下，只有當(dāng)線程A寫(xiě)好數(shù)據(jù)后線程B才能讀出，只有線程B讀出數(shù)據(jù)后線程A才能繼續(xù)寫(xiě)入數(shù)據(jù)，這兩個(gè)線程之間需要同步進(jìn)行通信。
工商網(wǎng)監(jiān)
評(píng)論