c++多线程（四）

线程间通信

主线程创建子线程必定会为主线程分担一部分工作，这样不可避免的会在这两个线程之间存在消息传递渠道，因此主线程和子线程之间要进行通信。

下面介绍几种通信方式：

全局变量：由于同一进程的各个线程之间共享该进程的资源，因此，解决线程间通信最简单的方式是使用全局变量。对于标准类型的全局变量，使用validate修饰符，不让编译器对其优化，因为编译器如果对其优化，可能会导致线程间读取数据的不准确。例如一个变量num:

[cpp] view
plaincopy

int num;

num = 1;

num = 2;

如果编译器进行优化，则会直接把2赋值给num。但是可能num=1,线程一使用；num=2，线程二使用。优化完以后则就发生数据不准确了。所以在前面的实例中，使用全局变量，都是带有validate修饰符。
自定义消息：

可以在一个线程中向另一个线程发送消息来实现线程之间的通信。一个线程向另一个线程发送消息是通过操作系统实现的。当一个线程发送一个消息，操纵系统首先接收到消息，然后把此消息转发到目的线程。

多线程实例6-----自定义消息实现线程间通信

此实例实现简单1到50,1到100,1到150相加，然后把相加结果显示出来。计算结果采用一个子线程实现（CalculateThread类，继承自CWinThread类），然后把计算结果通过消息发送给主线程。

部分代码：

CalculateThread.cpp

[cpp] view
plaincopy

// CalculateThread.cpp : implementation file

//

#include "stdafx.h"

#include "Mthread7.h"

#include "CalculateThread.h"

#include "Mthread7Dlg.h"

#ifdef _DEBUG

#define new DEBUG_NEW

#undef THIS_FILE

static char THIS_FILE[] = __FILE__;

#endif

/////////////////////////////////////////////////////////////////////////////

// CCalculateThread

IMPLEMENT_DYNCREATE(CCalculateThread, CWinThread)

CCalculateThread::CCalculateThread()

{

}

CCalculateThread::~CCalculateThread()

{

}

BOOL CCalculateThread::InitInstance()

{

// TODO: perform and per-thread initialization here

return TRUE;

}

int CCalculateThread::ExitInstance()

{

// TODO: perform any per-thread cleanup here

return CWinThread::ExitInstance();

}

BEGIN_MESSAGE_MAP(CCalculateThread, CWinThread)

//{{AFX_MSG_MAP(CCalculateThread)

// NOTE - the ClassWizard will add and remove mapping macros here.

ON_THREAD_MESSAGE(WM_CALCULATE,OnCalculate)

//}}AFX_MSG_MAP

END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////

// CCalculateThread message handlers

LRESULT CCalculateThread::OnCalculate(WPARAM wParam, LPARAM lParam)

{

int iTemp = 0;

for (int i=0; i<(int)wParam+1; i++)

{

iTemp = i + iTemp;

}

Sleep(500);

//::PostMessage(AfxGetMainWnd()->GetSafeHwnd(),WM_DISPLAY,iTemp,0);

PostMessage(GetMainWnd()->GetSafeHwnd(),WM_DISPLAY,iTemp,0);

return 0;

}

主线程主要是创建子线程，并且发送计算消息给子线程，并且把计算需要的参数通过消息发送给计算线程。

部分代码如下：

[cpp] view
plaincopy

LRESULT CCalculateThread::OnCalculate(WPARAM wParam, LPARAM lParam)

{

int iTemp = 0;

for (int i=0; i<(int)wParam+1; i++)

{

iTemp = i + iTemp;

}

Sleep(500);

//::PostMessage(AfxGetMainWnd()->GetSafeHwnd(),WM_DISPLAY,iTemp,0);

PostMessage(GetMainWnd()->GetSafeHwnd(),WM_DISPLAY,iTemp,0);

return 0;

}

执行结果：