C++的MFC線程技術(shù)

進程和線程的關(guān)系

程序→運行→進程
一個進程至少有一個線程,一個進程可以有多個線程
簡單的程序設(shè)計,一個進程一個線程,即主線程,若主線程需要進行大量運算時,會影響對話框的其他操作,表現(xiàn)為程序未響應(yīng)的阻塞狀態(tài)。
高級的程序設(shè)計,一個進程多個線程

一、 創(chuàng)建(啟動)線程

//創(chuàng)建線程函數(shù)
AfxBeginThread()
//線程函數(shù)
typedef UINT(AFX_CDECL *AFX THREADPROC)(LPVOID);

在VS上利用基于對話框的MFC編程,建立名為Demo的項目,如下窗口:


其中,從左到右的靜態(tài)文本框,分別改ID為:IDC_OUTPUT_1、IDC_OUTPUT_2、IDC_OUTPUT_3。按鈕默認。

1、button1直接用主線程

Demodlg.cpp中修改button1函數(shù)

//直接用主線程
void CDemoDlg::OnBnClickedButton1()
{
  // TODO:在此添加控件通知處理程序代碼
  for(int i=1; i<=100; i++)
  {
    SetDlgItemInt(IDC_OUTPUT_1, i);
    Sleep(1000);//等待1s
  }
}

運行:結(jié)果在點擊button1后,程序發(fā)生阻塞如下圖:


2、button2中調(diào)用線程函數(shù):

Demodlg.h中聲明線程函數(shù)(必須是全局):

//線程函數(shù)的名字可以任意,但是返回類型和參數(shù)必須如下
UINT DemoA(LPVOID pParam);

// CDemoDlg對話框
class CDemoDlg: public CDialogEx
{
  ....
}

Demodlg.cpp中定義線程函數(shù)

UINT DemoA(LPVOID pParam)
{
  for(int m=1; m<=100; m++)
  {
    //全局調(diào)用,獲得主窗口的句柄
    ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT_2, m,false);
    Sleep(500);
  }
  return 0:
}

Demodlg.cpp中修改button2函數(shù)

void CDemoDlg::OnBnClickedButton2()
{
  // TODO:在此添加控件通知處理程序代碼
  //調(diào)用線程
  AfxBeginThread (DemoA, NULL);//NULL:不傳遞線程函數(shù)的pParam參數(shù),pParam參數(shù)
}

這次運行后,就可以操作其他事件,不會發(fā)生阻塞。

3、button3中再調(diào)用線程函數(shù)DemoB:

創(chuàng)建方法類似,不再贅述。運行后button2、button3能獨立操作。

補充:

SetDlgItemInt函數(shù)的定義如下,該函數(shù)將uValue的值設(shè)為對話框控件的文本:

/*
(1)hDlg:指向?qū)υ捒虼翱诘木浔?(2)nIDDlgItem:要改變其文本的控件ID。
(3)uValue:指向要設(shè)置的值。
(4)bSigned:指定uValue是否為一個有符號的值。
*/
BOOL SetDlgItemInt(HWND hDlg,int nIDDlgItem,UINT uValue,BOOL bSigned);

二、 線程控制

線程的控制主要有:啟動線程、暫停(掛起)線程、繼續(xù)線程、終止線程。
將案例一的窗口修改如下,之前的button2改為啟動,依次再添加暫停、繼續(xù)、停止鍵:


Demodlg.cpp中定義全局變量用于保存線程指針:

CWinThread* g_pThreadA;

Demodlg.cpp構(gòu)造函數(shù)中初始化指針為NULL

CDemoDlg::CDemoDlg(CWnda pParent /*-NULL*/)
:CDialogEx(CDemoDlg::IDD, pParent)
{
  mhIcon = AfxGetApp()->LoadIcon(IDR_MAINPRAME);
  g_ThreadA = NULL:
}

Demodlg.cpp中完善案例一button2中的線程啟動函數(shù):

void CDemoDlg::OnBnClickedButton2()
{
  // TODO:在此添加控件通知處理程序代碼]
  if (g_pThreadA == NULL)
  {
    g_pThreadA = AfxBeginThread(DemoA, NULL);
  }
  else
  {
    AfxMessageBox(T("線程已經(jīng)啟動!"));
  }
 }
1、暫停線程

Demodlg.cpp中修改“暫停”按鈕事件函數(shù):

void CDemoDlg::OnBnClickedButtonSuspend()
{
  // TODO:在此添加控件通知處理程序代碼
  if(g_pThreadA == NULL)
  {
    AfxMessageBox(T("線程不存在!"));
  }
  else
  {
    g-pThreadA->SuspendThread(); //暫停,掛起
  }
}
2、繼續(xù)線程

Demodlg.cpp中修改“繼續(xù)”按鈕事件函數(shù):

void CDemoDlg::OnBnClickedButtonResume()
{
  // TODO:在此添加控件通知處理程序代碼
  if(g_pThreadA == NULL)
  {
    AfxMessageBox(T("線程不存在!"));
  }
  else
  {
    g-pThreadA->ResumeThread(); //暫停,掛起
  }
}
3、終止線程

Demodlg.cpp中再定義一個BOOL類型的全局變量

CWinThread* g_pThreadA;
BOOL g_bRunningA;

Demodlg.cpp構(gòu)造函數(shù)中初始化g_bRunningA變量

CDemoDlg::CDemoDlg(CWnda pParent /*-NULL*/)
:CDialogEx(CDemoDlg::IDD, pParent)
{
  mhIcon = AfxGetApp()->LoadIcon(IDR_MAINPRAME);
  g_ThreadA = NULL:
  g_bRunningA = FALSE;
}

Demodlg.cpp中完善button2按鈕的啟動函數(shù)

void CDemoDlg::OnBnClickedButton2()
{
  // TODO:在此添加控件通知處理程序代碼]
  if (g_pThreadA == NULL)
  {
    g_pThreadA = AfxBeginThread(DemoA, NULL);
    g_bRunningA = TRUE;
  }
  else
  {
    AfxMessageBox(T("線程已經(jīng)啟動!"));
  }
 }

Demodlg.cpp中修改“終止”按鈕事件函數(shù):

void CDemoDlg::OnBnClickedEnd()
{
  if(g_pThreadA == NULL)
  {
    AfxMessageBox(T("線程不存在!"));
  }
  else
  {
    g_bRunningA = FALSE;
  }
 }

Demodlg.cpp中修改線程函數(shù):

UINT DemoA(LPVOID pParam)
{
  for(int m=1; m<=100; m++)
  {
    if(!g_bRunningA)  break;
    //全局調(diào)用,獲得主窗口的句柄
    ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT_2, m,false);
    Sleep(500);
  }
  g_pThreadA = NULL;
  g_bRunningA = FALSE;
  return 0:
}

運行:能夠暫停、繼續(xù)、終止線程。

三、 線程同步

線程同步:一次只允許一個線程對共享資源進行操作。
在VS上利用基于對話框的MFC編程,建立名為Demo的項目,如下窗口:

1、建立第一個線程

Demodlg.h中聲明線程函數(shù):

//ThreadProcA為函數(shù)名,可以任意
UINT ThreadProcA(LPVDID pParam);
// CDemoDlg對話框
class CDemoDlg: public CDialogEx
{
  ....
}

Demodlg.cpp中定義線程函數(shù):

//定義兩個全局變量作為共享資源
int k = 1;
int total = 0:
UINT ThreadProcA(LPVOID pParam)
{
  for(int i=1; i<=100000000; i++)
  {
    k = k*2:
    k = k/2;
    total += k;
  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}

Demodlg.cpp中修改button1的事件函數(shù)調(diào)用線程:

void CDemoDlg::OnBnClickedButton1()
{
  // TODO:在此添加控件通知處理程序代碼
  AfxBeginThread(ThreadProcA, NULL);
}
2、新建按鈕調(diào)用第二個線程函數(shù)


Demodlg.h中聲明線程函數(shù)ThreadProcB:

//ThreadProcA為函數(shù)名,可以任意
UINT ThreadProcA(LPVDID pParam);
//ThreadProcB為函數(shù)名,可以任意
UINT ThreadProcB(LPVDID pParam);
// CDemoDlg對話框
class CDemoDlg: public CDialogEx
{
  ....
}

Demodlg.cpp中定義線程函數(shù)ThreadProcB:

UINT ThreadProcB(LPVOID pParam)
{
  for(int j=1; j<=100000000; j++)
  {
    k = k*2:
    k = k/2;
    total += k;
  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}

Demodlg.cpp中修改button2的事件函數(shù)調(diào)用線程:

void CDemoDlg::OnBnClickedButton2()
{
  // TODO:在此添加控件通知處理程序代碼
  AfxBeginThread(ThreadProcB, NULL);
}
運行結(jié)果:

如果按完button1后,一段時間后按button2,則顯示200000000,符合預(yù)期;
如果按完button1后,立即按button2,顯示結(jié)果不可預(yù)知。這是因為另一個按鈕button2用了button1線程函數(shù)中k,total變量的中間結(jié)果。

分析:

下述線程函數(shù)的循環(huán)體為臨界區(qū)域代碼:

k = k*2:
k = k/2;
total += k;

每個線程函數(shù)進入臨界區(qū)域代碼前應(yīng)該加鎖,執(zhí)行完臨界區(qū)域代碼后要解鎖。

3、線程同步的方法

線程同步的方法主要有4中:臨界區(qū)CCriticalSection、互斥量CMutex、信號量CSemahore、事件CEvent

①臨界區(qū)(關(guān)鍵區(qū))

Demodlg.cpp中定義全局指針變量g_pCS指向臨界區(qū)對象:

CCriticalSection* g_pCS;

Demodlg.cpp構(gòu)造函數(shù)中創(chuàng)建臨界區(qū)對象

CDemoDlg::CDemoDlg(CWnda pParent /*-NULL*/)
:CDialogEx(CDemoDlg::IDD, pParent)
{
  mhIcon = AfxGetApp()->LoadIcon(IDR_MAINPRAME);
  g_pCS = new CCriticalSection();//有new就要有delete
}

Demodlg.h中聲明析構(gòu)函數(shù)~CDemoDlg()

class CDemoDlg: public CDialogEx
{
  //構(gòu)造
  public:
  CDemoDlg(CWnd* pParent = NULL) ; //標準構(gòu)造函數(shù)
  ~CDemoDlg();//析構(gòu)函數(shù)
  //對話框數(shù)據(jù)
  enum { IDD = IDD_DEMO_DIALOG };
  .......
}

Demodlg.cpp中定義析構(gòu)函數(shù)~CDemoDlg()

CDemoDlg::~CDemoDlg()
{
  delete g_pCS;
  g_pCS = NULL;
} 

Demodlg.cpp線程函數(shù)中給臨界區(qū)代碼加鎖:

//線程一
UINT ThreadProcA(LPVOID pParam)
{
  for(int i=1; i<=100000000; i++)
  {
    g_pCS->Lock();//加鎖
    k = k*2:
    k = k/2;
    total += k;
    g_pCS->Unlock();//解鎖
  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}


//線程二
UINT ThreadProcB(LPVOID pParam)
{
  for(int j=1; j<=100000000; j++)
  {
    g_pCS->Lock();//加鎖
    k = k*2:
    k = k/2;
    total += k;
    g_pCS->Unlock();//解鎖
  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}

結(jié)果:運行速度變慢,但結(jié)果正確。是4種方法中運算最快的!

②互斥量

Demodlg.cpp中定義全局指針變量g_pMutex指向互斥量對象:

CMutex* g_pMutex;

Demodlg.cpp構(gòu)造函數(shù)中創(chuàng)建互斥量對象

CDemoDlg::CDemoDlg(CWnda pParent /*-NULL*/)
:CDialogEx(CDemoDlg::IDD, pParent)
{
  mhIcon = AfxGetApp()->LoadIcon(IDR_MAINPRAME);
  g_pMutex = new CMutex();//有new就要有delete
}

Demodlg.h中聲明析構(gòu)函數(shù)~CDemoDlg()

class CDemoDlg: public CDialogEx
{
  //構(gòu)造
  public:
  CDemoDlg(CWnd* pParent = NULL) ; //標準構(gòu)造函數(shù)
  ~CDemoDlg();//析構(gòu)函數(shù)
  //對話框數(shù)據(jù)
  enum { IDD = IDD_DEMO_DIALOG };
  .......
}

Demodlg.cpp中定義析構(gòu)函數(shù)~CDemoDlg()

CDemoDlg::~CDemoDlg()
{
  delete g_pMutex;
  g_pMutex = NULL;
} 

Demodlg.cpp線程函數(shù)中給臨界區(qū)代碼加鎖:

//線程一
UINT ThreadProcA(LPVOID pParam)
{
  CSingleLock singleLock(g_pMutex) ;
  for(int j=1; j<=100000000; j++)
  {
    singleLock.Lock();
    if(singleLock.IsLocked())
    {
      k = k*2:
      k = k/2;
      total += k;
      singleLock.Unlock();
    }

  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}


//線程二
UINT ThreadProcB(LPVOID pParam)
{
  CSingleLock singleLock(g_pMutex) ;
  for(int i=1; i<=100000000; i++)
  {
    singleLock.Lock();
    if(singleLock.IsLocked())
    {
      k = k*2:
      k = k/2;
      total += k;
      singleLock.Unlock();
    }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}

運行結(jié)果:顯示結(jié)果正確,運算特別慢。

③信號量

Demodlg.cpp中定義全局指針變量g_pSemaphore指向信號量對象:

CSemaphore* g_pSemaphore;

Demodlg.cpp構(gòu)造函數(shù)中創(chuàng)建信號量對象

CDemoD1g::CDemoDlg(CWnd* pParent /*=NULL*/)
: CDialogEx(CDemoDlg::IDD, pParent)
{
   m_hIcon = AfxGetApp()->LoadIcon(IDR MAINFRAME):
   g_pSemaphore = new CSemaphore(1,1);//初始計數(shù)是1,最大計數(shù)是1,實際上信號量很復(fù)雜,可以用于復(fù)雜的線程同步。
}

Demodlg.h中聲明析構(gòu)函數(shù)~CDemoDlg()

class CDemoDlg: public CDialogEx
{
  //構(gòu)造
  public:
  CDemoDlg(CWnd* pParent = NULL) ; //標準構(gòu)造函數(shù)
  ~CDemoDlg();//析構(gòu)函數(shù)
  //對話框數(shù)據(jù)
  enum { IDD = IDD_DEMO_DIALOG };
  .......
}

Demodlg.cpp中定義析構(gòu)函數(shù)~CDemoDlg()

CDemoDlg::~CDemoDlg()
{
  delete g_pSemaphore;
  g_pSemaphore = NULL;
} 

Demodlg.cpp線程函數(shù)中給臨界區(qū)代碼加鎖,和互斥量代碼非常相似:

//線程一
UINT ThreadProcA(LPVOID pParam)
{
  CSingleLock singleLock(g_pSemaphore) ;
  for(int j=1; j<=100000000; j++)
  {
    singleLock.Lock();
    if(singleLock.IsLocked())
    {
      k = k*2:
      k = k/2;
      total += k;
      singleLock.Unlock();
    }

  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}


//線程二
UINT ThreadProcB(LPVOID pParam)
{
  CSingleLock singleLock(g_pSemaphore) ;
  for(int i=1; i<=100000000; i++)
  {
    singleLock.Lock();
    if(singleLock.IsLocked())
    {
      k = k*2:
      k = k/2;
      total += k;
      singleLock.Unlock();
    }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}

運行結(jié)果:顯示結(jié)果正確,運算特別慢。

④事件

Demodlg.cpp中定義全局指針變量g_pEvent指向事件對象:

CEvent* g_pEvent;

Demodlg.cpp構(gòu)造函數(shù)中創(chuàng)建事件對象

CDemoD1g::CDemoDlg(CWnd* pParent /*=NULL*/)
: CDialogEx(CDemoDlg::IDD, pParent)
{
   m_hIcon = AfxGetApp()->LoadIcon(IDR MAINFRAME):
    g_pEvent = new CEvent(TRUE);
}

Demodlg.h中聲明析構(gòu)函數(shù)~CDemoDlg()

class CDemoDlg: public CDialogEx
{
  //構(gòu)造
  public:
  CDemoDlg(CWnd* pParent = NULL) ; //標準構(gòu)造函數(shù)
  ~CDemoDlg();//析構(gòu)函數(shù)
  //對話框數(shù)據(jù)
  enum { IDD = IDD_DEMO_DIALOG };
  .......
}

Demodlg.cpp中定義析構(gòu)函數(shù)~CDemoDlg()

CDemoDlg::~CDemoDlg()
{
  delete g_pEvent;
  g_pEvent = NULL;
} 

Demodlg.cpp線程函數(shù)中給臨界區(qū)代碼加鎖:

//線程一
UINT ThreadProcA(LPVOID pParam)
{
  CSingleLock singleLock(g_pEvent) ;
  for(int j=1; j<=100000000; j++)
  {
    singleLock.Lock();
    if(singleLock.IsLocked())
    {
      k = k*2:
      k = k/2;
      total += k;
      singleLock.Unlock();
      g_pEvent->SetEvent();//發(fā)信號給其他線程
    }

  }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}


//線程二
UINT ThreadProcB(LPVOID pParam)
{
  CSingleLock singleLock(g_pEvent) ;
  for(int i=1; i<=100000000; i++)
  {
    singleLock.Lock();
    if(singleLock.IsLocked())
    {
      k = k*2:
      k = k/2;
      total += k;
      singleLock.Unlock();
      g_pEvent->SetEvent();//發(fā)信號給其他線程
    }
  ::SetDlgItemInt(AfxGetApp()->mpMainWnd->mhWnd, IDC_OUTPUT, total,false);
  return 0;
}

運行結(jié)果:顯示結(jié)果正確,運算特別慢。
4種方法種最快的是臨界區(qū)對象。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • 1.C和C++的區(qū)別?C++的特性?面向?qū)ο缶幊痰暮锰帲?答:c++在c的基礎(chǔ)上增添類,C是一個結(jié)構(gòu)化語言,它的重...
    杰倫哎呦哎呦閱讀 9,994評論 0 45
  • 1.面向?qū)ο蟮某绦蛟O(shè)計思想是什么? 答:把數(shù)據(jù)結(jié)構(gòu)和對數(shù)據(jù)結(jié)構(gòu)進行操作的方法封裝形成一個個的對象。 2.什么是類?...
    少帥yangjie閱讀 5,120評論 0 14
  • 1歲半的元元已經(jīng)能說很多詞了, 比如“不要”、“小車車”、“校”、“下”、“尿”、“水”、“鞋”、“幣”、“謝謝”...
    若汐_44ae閱讀 185評論 0 0
  • 辦公室里彌漫著煙霧的氣息,室內(nèi)的溫暖如春與外面的寒冬形成了鮮明的對比,狂風和雪花叫囂著要壓倒一切,無奈這個...
    郭家二少閱讀 312評論 0 0

友情鏈接更多精彩內(nèi)容