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