四、MFC多線程間通信
1.線程之間的通信簡介
一般而言,在一個應用程序中(即進程),一個線程往往不是孤立存在的,常常需要和其它線程通信,以執行特定的任務。如主線程和次線程,次線程與次線程,工作線程和用戶界面線程等。這樣,線程與線程間必定有一個信息傳遞的渠道。這種線程間的通信不但是難以避免的,而且在多線程編程中也是復雜和頻繁的。線程間的通信涉及到4個問題:
?。?) 線程間如何傳遞信息
?。?) 線程之間如何同步,以使一個線程的活動不會破壞另一個線程的活動,以保證計算結果的正確合理
?。?) 當線程間具有依賴關系時,如何調度多個線程的處理順序
?。?) 如何避免死鎖問題
在windows系統中線程間的通信一般采用四種方式:全局變量方式、消息傳遞方式、參數傳遞方式和線程同步法。下面分別作介紹。
2.全局變量方式
由于屬于同一個進程的各個線程共享操作系統分配該進程的資源,故解決線程間通信最簡單的一種方法是使用全局變量。對于標準類型的全局變量,我們建議使用volatile 修飾符,它告訴編譯器無需對該變量作任何的優化,即無需將它放到一個寄存器中,并且該值可被外部改變。
實例演示
該實例采用全局變量來控制時間顯示線程的顯示格式,比較簡單。
主要的代碼如下:
.h頭文件
//線程函數聲明
DWORD WINAPIThreadProc(LPVOIDlpParam);
protected:
HANDLE m_hThread;//線程句柄
DWORD m_nThread;//線程ID
.cpp實現文件
volatileBYTE m_nShowFlag = 31;//定義全局變量,用于控制顯示時間的格式。volatile 修飾符的作用是告訴編譯器無需對該變量作任何的優化,即無需將它放到一個寄存器中。
//創建顯示時間的線程,參數無
m_hThread =CreateThread(NULL,0,ThreadProc,NULL,0,&m_nThread);
//線程執行函數,用于實時顯示時間,并按規定格式顯示
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)
{//周數
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;
}
運行效果:
工程源碼下載地址:
http://download.csdn.net/detail/cbnotes/4962315
注意事項:
?。?) 全局變量最好放在.CPP文件的起始處,而不要放在.h頭文件中,否則將出現重復鏈接的編譯錯誤。定義全局變量時最好顯式初始化,默認初始值為零。
?。?) 注意語句
::SetDlgItemText(AfxGetMainWnd()-》m_hWndIDC_STATIC_TIME,strTime);在VC6.0中可以通過,但在VC2008卻出錯,這是因為在VC2008中不支持AfxGetMainWnd()-》m_hWnd來獲取HWND,但可以采AfxGetApp()-》m_pMainWnd-》m_hWnd來獲取。所以上面的語句更改為:
?。海篠etDlgItemText(AfxGetApp()-》m_pMainWnd-》m_hWnd,IDC_STATIC_TIME,strTime);
?。?) 用全局變量方式來實現多線程的通信比較簡單實用,單注意最好不要多個線程對它進行修改,否則將可能出錯,這將在后面會具體講解。
3.參數傳遞方式
該方式是線程通信的官方標準方法,多數情況下,主線程創建子線程并讓其子線程為其完成特定的任務,主線程在創建子線程時,可以通過傳給線程函數的參數和其通信,三類創建線程的函數都支持參數的傳遞(哪三類?看前面的介紹吧?。?。所傳遞的參數是一個32位的指針,該指針不但可以指向簡單的數據,而且可以指向結構體或類等復雜的抽象數據類型。
實例演示
下面將分別簡單演示三類創建線程時提供參數傳遞的方法。
主要的代碼如下:
.h頭文件
//線程函數聲明
DWORD WINAPI ThreadFunc1(LPVOID lpParam);//線程函數
void ThreadFunc2(void *pArg); //線程函數
UINT ThreadFunc3(LPVOID lpParam);//線程函數
//全局函數
POINT GetRandPoint();//得到隨機點的坐標
//結構體定義,用于向線程傳遞多個參數
struct threadInfo
{
HWND hWnd;//主窗口句柄
COLORREF clrPen;//畫筆顏色
};
.cpp實現文件
//開始創建線程:創建個線程
void CMultThreadComm2Dlg::OnStart(void)
{
//線程:使用win32 API 創建:實時顯示時間
m_hThread1 = CreateThread(NULL,0,ThreadFunc1,&m_stTime.m_hWnd,0,NULL);//
//線程:使用CRT 創建:隨機畫線
m_info.hWnd = m_hWnd;
m_info.clrPen =RGB(255,0,0);
_beginthread(ThreadFunc2,0,&m_info);
//線程:使用MFC線程函數創建:顯示進度
m_pThread = AfxBeginThread(ThreadFunc3,&m_ctrlProgress);
}
//停止/開始
void CMultThreadComm2Dlg::OnBnClickedButton1()
{
// TODO: 在此添加控件通知處理程序代碼
CString szTitle;
GetDlgItemText(IDC_BUTTON1,szTitle);
if (szTitle == “停止”)
{//停止
g_bRun = false;
SetDlgItemText(IDC_BUTTON1,“開始”);
}
else
{//開始
g_bRun = true;
OnStart();
SetDlgItemText(IDC_BUTTON1,“停止”);
}
}
//線程執行函數:實時顯示當前的時間
DWORD WINAPI ThreadFunc1(LPVOID lpParam)
{
HWND *hWnd = (HWND*)lpParam;
//CWnd *pWnd = AfxGetApp()-》m_pMainWnd;//當沒有傳遞參數時,可以用該api實現
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;
}
//線程執行函數:隨機畫線
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);
}
//線程執行函數:顯示進度
UINT ThreadFunc3(LPVOIDlpParam)
{
CProgressCtrl *pProgress= (CProgressCtrl*)lpParam;
while(g_bRun)
{
pProgress-》StepIt();
Sleep(500);
}
return 0;
}
//得到隨機點
POINT GetRandPoint()
{
POINT Point;
Point.x = rand()%439;
Point.y = rand()%208;
return Point;
}
運行效果:
工程源碼下載地址:
http://download.csdn.net/detail/cbnotes/4984274
注意事項:
?。?) 注意三類線程的創建方法和各自的線程函數的格式(返回類型各不一樣)。
(2) 注意三類參數的傳遞:單個參數、多參數(結構體),復雜參數(類)。
(3) 采用參數傳遞方式進行線程間的通信只適用于主線程向從線程的通信。
?。?) 不知道大家看出該程序的一個BUG沒有(大家可以下載工程源碼,編譯并運行,可以很明顯的發現。),就是線程二的隨機畫線線程,原意是隨機畫線并清除,但運行發現第一次畫線時總是沒有被清除掉,為什么?望大家動腦,知道的可以留言,大家一起學習和討論!
評論