摘要:本文主要以MFC多線程為中心,分別對MFC多線程的實例、MFC多線程之間的通信展開的一系列研究,下面我們來看看原文。
一、多線程概述
進程和線程都是操作系統的概念。進程是應用程序的執行實例,每個進程是由私有的虛擬地址空間、代碼、數據和其它各種系統資源組成,進程在運行過程中創建的資源隨著進程的終止而被銷毀,所使用的系統資源在進程終止時被釋放或關閉。
線程是進程內部的一個執行單元。系統創建好進程后,實際上就啟動執行了該進程的主執行線程,主執行線程以函數地址形式,比如說main或WinMain函數,將程序的啟動點提供給Windows系統。主執行線程終止了,進程也就隨之終止。
每一個進程至少有一個主執行線程,它無需由用戶去主動創建,是由系統自動創建的。用戶根據需要在應用程序中創建其它線程,多個線程并發地運行于同一個進 程中。一個進程中的所有線程都在該進程的虛擬地址空間中,共同使用這些虛擬地址空間、全局變量和系統資源,所以線程間的通訊非常方便,多線程技術的應用也 較為廣泛。
多線程可以實現并行處理,避免了某項任務長時間占用CPU時間。要說明的一點是,目前大多數的計算機都是單處理器(CPU)的,為了運行所有這些線程, 操作系統為每個獨立線程安排一些CPU時間,操作系統以輪換方式向線程提供時間片,這就給人一種假象,好象這些線程都在同時運行。由此可見,如果兩個非常 活躍的線程為了搶奪對CPU的控制權,在線程切換時會消耗很多的CPU資源,反而會降低系統的性能。這一點在多線程編程時應該注意。
二、MFC對多線程編程的支持
MFC中有兩類線程,分別稱之為工作者線程和用戶界面線程。二者的主要區別在于工作者線程沒有消息循環,而用戶界面線程有自己的消息隊列和消息循環。
工作者線程沒有消息機制,通常用來執行后臺計算和維護任務,如冗長的計算過程,打印機的后臺打印等。用戶界面線程一般用于處理獨立于其他線程執行之外的用戶輸入,響應用戶及系統所產生的事件和消息等。但對于Win32的API編程而言,這兩種線程是沒有區別的,它們都只需線程的啟動地址即可啟動線程來執行任務。
在MFC中,一般用全局函數AfxBeginThread()來創建并初始化一個線程的運行,該函數有兩種重載形式,分別用于創建工作者線程和用戶界面線程。兩種重載函數原型和參數分別說明如下:
(1) CWinThread* AfxBeginThread(AFX_THREADPROC pfnThreadProc,
LPVOID pParam,
nPriority=THREAD_PRIORITY_NORMAL,
UINT nStackSize=0,
DWORD dwCreateFlags=0,
LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);
PfnThreadProc:指向工作者線程的執行函數的指針,線程函數原型必須聲明如下: UINT ExecutingFunction(LPVOID pParam);
請注意,ExecutingFunction()應返回一個UINT類型的值,用以指明該函數結束的原因。一般情況下,返回0表明執行成功。
pParam:傳遞給線程函數的一個32位參數,執行函數將用某種方式解釋該值。它可以是數值,或是指向一個結構的指針,甚至可以被忽略;
nPriority:線程的優先級。如果為0,則線程與其父線程具有相同的優先級;
nStackSize:線程為自己分配堆棧的大小,其單位為字節。如果 nStackSize被設為0,則線程的堆棧被設置成與父線程堆棧相同大小;
dwCreateFlags:如果為0,則線程在創建后立刻開始執行。如果為CREATE_SUSPEND,則線程在創建后立刻被掛起;
lpSecurityAttrs:線程的安全屬性指針,一般為 NULL;
(2) CWinThread* AfxBeginThread(CRuntimeClass* pThreadClass,
int nPriority=THREAD_PRIORITY_NORMAL,
UINT nStackSize=0,
DWORD dwCreateFlags=0,
LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);
pThreadClass 是指向 CWinThread 的一個導出類的運行時類對象的指針,該導出類定義了被創建的用戶界面線程的啟動、退出等;其它參數的意義同形式1。使用函數的這個原型生成的線程也有消息機制,在以后的例子中我們將發現同主線程的機制幾乎一樣。
下面我們對CWinThread類的數據成員及常用函數進行簡要說明。
m_hThread:當前線程的句柄;
m_nThreadID:當前線程的ID;
m_pMainWnd:指向應用程序主窗口的指針
BOOL CWinThread::CreateThread(DWORD dwCreateFlags=0,
UINT nStackSize=0,
LPSECURITY_ATTRIBUTES lpSecurityAttrs=NULL);
該函數中的dwCreateFlags、nStackSize、lpSecurityAttrs參數和API函數CreateThread中的對應參數有相同含義,該函數執行成功,返回非0值,否則返回0。
一般情況下,調用AfxBeginThread()來一次性地創建并啟動一個線程,但是也可以通過兩步法來創建線程:首先創建CWinThread類的一個對象,然后調用該對象的成員函數CreateThread()來啟動該線程。
virtual BOOL CWinThread::InitInstance();
重載該函數以控制用戶界面線程實例的初始化。初始化成功則返回非0值,否則返回0。用戶界面線程經常重載該函數,工作者線程一般不使用 InitInstance()。 virtual int CWinThread::ExitInstance();
在線程終結前重載該函數進行一些必要的清理工作。該函數返回線程的退出碼,0表示執行成功,非0值用來標識各種錯誤。同 InitInstance()成員函數一樣,該函數也只適用于用戶界面線程。
三、MFC多線程編程實例
在Visual C++
6.0編程環境中,我們既可以編寫C風格的32位Win32應用程序,也可以利用MFC類庫編寫C++風格的應用程序,二者各有其優缺點。
基于Win32的應用程序執行代碼小巧,運行效率高,但要求程序員編寫的代碼較多,且需要管理系統提供給程序的所有資源;而基于MFC類庫的應用程序可以快速建立起應用程序,類庫為程序員提供了大量的封裝類,而且DeveloperStudio為程序員提供了一些工具來管理用戶源程序,其缺點是類庫代碼很龐大。由于使用類庫所帶來的快速、簡捷和功能強大等優越性,因此除非有特殊的需要,否則VisualC++推薦使用MFC類庫進行程序開發。
我們知道,MFC中的線程分為兩種:用戶界面線程和工作者線程。我們將分別舉例說明。
用 MFC 類庫編程實現工作者線程
例程5 MultiThread5
為了與Win32 API對照,我們使用MFC 類庫編程實現例程3 MultiThread3。
建立一個基于對話框的工程MultiThread5,在對話框IDD_MULTITHREAD5_DIALOG中加入一個編輯框 IDC_MILLISECOND,一個按鈕IDC_START,標題為“開始” ,一個進度條IDC_PROGRESS1;
打開 ClassWizard,為編輯框IDC_MILLISECOND添加int型變量m_nMilliSecond,為進度條IDC_PROGRESS1添加CProgressCtrl型變量m_ctrlProgress;
在MultiThread5Dlg.h文件中添加一個結構的定義: struct threadInfo
{
UINT nMilliSecond;
CProgressCtrl* pctrlProgress;
};
線程函數的聲明:UINT ThreadFunc(LPVOID lpParam);
注意,二者應在類CMultiThread5Dlg 的外部。
在類CMultiThread5Dlg內部添加protected型變量:
CWinThread* pThread;
在MultiThread5Dlg.cpp文件中進行如下操作:定義公共變量:threadInfo Info;
雙擊按鈕IDC_START,添加相應消息處理函數:
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);
}
在函數BOOL CMultiThread3Dlg::OnInitDialog()中添加語句: {
……
// 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
}
添加線程處理函數: 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 類庫編程實現用戶界面線程
創建用戶界面線程的步驟:
使用ClassWizard創建類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()
};
重載函數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;
}
創建新的用戶界面線程 void CUIThreadDlg::OnButton1()
{
CUIThread* pThread=new CUIThread();
pThread-》CreateThread();
}
請注意以下兩點:
A、在UIThreadDlg.cpp的開頭加入語句: #include “UIThread.h”
B、把UIThread.h中類 CUIThread()的構造函數的特性由 protected 改為 public。
用戶界面線程的執行次序與應用程序主線程相同,首先調用用戶界面線程類的InitInstance()函數,如果返回TRUE,繼續調用線程的Run()函數,該函數的作用是運行一個標準的消息循環,并且當收到WM_QUIT消息后中斷,在消息循環過程中,Run()函數檢測到線程空閑時(沒有消息),也將調用OnIdle()函數,最后Run()函數返回,MFC調用ExitInstance()函數清理資源。
你可以創建一個沒有界面而有消息循環的線程,例如:你可以從CWinThread 派生一個新類,在InitInstance函數中完成某項任務并返回FALSE,這表示僅執行InitInstance函數中的任務而不執行消息循環,你可以通過這種方法,完成一個工作者線程的功能。
四、MFC多線程間通信
1.線程之間的通信簡介
一般而言,在一個應用程序中(即進程),一個線程往往不是孤立存在的,常常需要和其它線程通信,以執行特定的任務。如主線程和次線程,次線程與次線程,工作線程和用戶界面線程等。這樣,線程與線程間必定有一個信息傳遞的渠道。這種線程間的通信不但是難以避免的,而且在多線程編程中也是復雜和頻繁的。線程間的通信涉及到4個問題:
(1) 線程間如何傳遞信息
(2) 線程之間如何同步,以使一個線程的活動不會破壞另一個線程的活動,以保證計算結果的正確合理
(3) 當線程間具有依賴關系時,如何調度多個線程的處理順序
(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);
::SetDlgItemText(AfxGetApp()-》m_pMainWnd-》m_hWnd,IDC_STATIC_TIME,strTime);
Sleep(100);
}
return 0;
}
運行效果:
工程源碼下載地址:
http://download.csdn.net/detail/cbnotes/4962315
注意事項:
(1) 全局變量最好放在.CPP文件的起始處,而不要放在.h頭文件中,否則將出現重復鏈接的編譯錯誤。定義全局變量時最好顯式初始化,默認初始值為零。
(2) 注意語句
::SetDlgItemText(AfxGetMainWnd()-》m_hWndIDC_STATIC_TIME,strTime);在VC6.0中可以通過,但在VC2008卻出錯,這是因為在VC2008中不支持AfxGetMainWnd()-》m_hWnd來獲取HWND,但可以采AfxGetApp()-》m_pMainWnd-》m_hWnd來獲取。所以上面的語句更改為:
::SetDlgItemText(AfxGetApp()-》m_pMainWnd-》m_hWnd,IDC_STATIC_TIME,strTime);
(3) 用全局變量方式來實現多線程的通信比較簡單實用,單注意最好不要多個線程對它進行修改,否則將可能出錯,這將在后面會具體講解。
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
注意事項:
(1) 注意三類線程的創建方法和各自的線程函數的格式(返回類型各不一樣)。
(2) 注意三類參數的傳遞:單個參數、多參數(結構體),復雜參數(類)。
(3) 采用參數傳遞方式進行線程間的通信只適用于主線程向從線程的通信。
(4) 不知道大家看出該程序的一個BUG沒有(大家可以下載工程源碼,編譯并運行,可以很明顯的發現。),就是線程二的隨機畫線線程,原意是隨機畫線并清除,但運行發現第一次畫線時總是沒有被清除掉,為什么?望大家動腦,知道的可以留言,大家一起學習和討論!
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才能繼續寫入數據,這兩個線程之間需要同步進行通信。
評論