博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
多线程编程之三——线程间通讯
阅读量:7060 次
发布时间:2019-06-28

本文共 3423 字,大约阅读时间需要 11 分钟。

七、线程间通讯

一般而言,应用程序中的一个次要线程总是为主线程执行特定的任务,这样,主线程和次要线程间必定有一个信息传递的渠道,也就是主线程和次要线程间要进行通信。这种线程间的通信不但是难以避免的,而且在多线程编程中也是复杂和频繁的,下面将进行说明。

使用全局变量进行通信

由于属于同一个进程的各个线程共享操作系统分配该进程的资源,故解决线程间通信最简单的一种方法是使用全局变量。对于标准类型的全局变量,我们建议使用volatile 修饰符,它告诉编译器无需对该变量作任何的优化,即无需将它放到一个寄存器中,并且该值可被外部改变。如果线程间所需传递的信息较复杂,我们可以定义一个结构,通过传递指向该结构的指针进行传递信息。

使用自定义消息

我们可以在一个线程的执行函数中向另一个线程发送自定义的消息来达到通信的目的。一个线程向另外一个线程发送消息是通过操作系统实现的。利用Windows操作系统的消息驱动机制,当一个线程发出一条消息时,操作系统首先接收到该消息,然后把该消息转发给目标线程,接收消息的线程必须已经建立了消息循环。

例程7 MultiThread7

该例程演示了如何使用自定义消息进行线程间通信。首先,主线程向CCalculateThread线程发送消息WM_CALCULATE,CCalculateThread线程收到消息后进行计算,再向主线程发送WM_DISPLAY消息,主线程收到该消息后显示计算结果。

建立一个基于对话框的工程MultiThread7,在对话框IDD_MULTITHREAD7_DIALOG中加入三个单选按钮IDC_RADIO1,IDC_RADIO2,IDC_RADIO3,标题分别为1+2+3+4+......+10,1+2+3+4+......+50,1+2+3+4+......+100。加入按钮IDC_SUM,标题为“求和”。加入标签框IDC_STATUS,属性选中“边框”;

在MultiThread7Dlg.h中定义如下变量:

1.
protected:
2.
    int nAddend;

代表加数的大小。

分别双击三个单选按钮,添加消息响应函数:

01.
void CMultiThread7Dlg::OnRadio1() 
02.
{
03.
    nAddend=10;
04.
}
05.
  
06.
void CMultiThread7Dlg::OnRadio2() 
07.
{
08.
    nAddend=50;
09.
      
10.
}
11.
  
12.
void CMultiThread7Dlg::OnRadio3() 
13.
{
14.
    nAddend=100;
15.
      
16.
}

并在OnInitDialog函数中完成相应的初始化工作:

1.
BOOL CMultiThread7Dlg::OnInitDialog()
2.
{
3.
……
4.
    ((CButton*)GetDlgItem(IDC_RADIO1))->SetCheck(TRUE);
5.
    nAddend=10;
6.
……

在MultiThread7Dlg.h中添加:

01.
#include "CalculateThread.h"
02.
#define WM_DISPLAY WM_USER+2
03.
class CMultiThread7Dlg : public CDialog
04.
{
05.
// Construction
06.
public:
07.
    CMultiThread7Dlg(CWnd* pParent = NULL); // standard constructor
08.
    CCalculateThread* m_pCalculateThread;
09.
……
10.
protected:
11.
    int nAddend;
12.
    LRESULT OnDisplay(WPARAM wParam,LPARAM lParam);
13.
……

在MultiThread7Dlg.cpp中添加:

 
01.
BEGIN_MESSAGE_MAP(CMultiThread7Dlg, CDialog)
02.
……
03.
    ON_MESSAGE(WM_DISPLAY,OnDisplay)
04.
END_MESSAGE_MAP()
05.
  
06.
LRESULT CMultiThread7Dlg::OnDisplay(WPARAM wParam,LPARAM lParam)
07.
{
08.
    int nTemp=(int)wParam;
09.
    SetDlgItemInt(IDC_STATUS,nTemp,FALSE);
10.
  
11.
  return 0;
12.
  
13.
}

以上代码使得主线程类CMultiThread7Dlg可以处理WM_DISPLAY消息,即在IDC_STATUS标签框中显示计算结果。

双击按钮IDC_SUM,添加消息响应函数:

01.
void CMultiThread7Dlg::OnSum() 
02.
{
03.
    m_pCalculateThread=
04.
        (CCalculateThread*)AfxBeginThread(RUNTIME_CLASS(CCalculateThread));
05.
  
06.
    Sleep(500);
07.
  
08.
    m_pCalculateThread->PostThreadMessage(WM_CALCULATE,nAddend,NULL);
09.
}

OnSum()函数的作用是建立CalculateThread线程,延时给该线程发送WM_CALCULATE消息。

右击工程并选中“New Class…”为工程添加基类为 CWinThread 派生线程类 CCalculateThread。

在文件CalculateThread.h 中添加

1.
#define WM_CALCULATE WM_USER+1 
2.
class CCalculateThread : public CWinThread
3.
{
4.
……
5.
protected:
6.
    afx_msg LONG OnCalculate(UINT wParam,LONG lParam);
7.
……

在文件CalculateThread.cpp中添加

01.
LONG CCalculateThread::OnCalculate(UINT wParam,LONG lParam)
02.
{
03.
    int nTmpt=0;
04.
    for(int i=0;i<=(int)wParam;i++)
05.
    {
06.
        nTmpt=nTmpt+i;
07.
    }
08.
  
09.
    Sleep(500);
10.
    ::PostMessage((HWND)(GetMainWnd()->GetSafeHwnd()),WM_DISPLAY,nTmpt,NULL);
11.
  
12.
    return 0;
13.
}
14.
BEGIN_MESSAGE_MAP(CCalculateThread, CWinThread)
15.
    //{
{AFX_MSG_MAP(CCalculateThread)
16.
        // NOTE - the ClassWizard will add and remove mapping macros here.
17.
    //}}AFX_MSG_MAP
18.
    ON_THREAD_MESSAGE(WM_CALCULATE,OnCalculate)
19.
//和主线程对比,注意它们的区别
20.
END_MESSAGE_MAP()

在CalculateThread.cpp文件的开头添加一条:

1.
#include "MultiThread7Dlg.h"

以上代码为 CCalculateThread 类添加了 WM_CALCULATE 消息,消息的响应函数是 OnCalculate,其功能是根据参数 wParam 的值,进行累加,累加结果在临时变量nTmpt中,延时0.5秒,向主线程发送WM_DISPLAY消息进行显示,nTmpt作为参数传递。

编译并运行该例程,体会如何在线程间传递消息。

<linker : >

转载地址:http://zdyll.baihongyu.com/

你可能感兴趣的文章
/dev/random和/dev/urandom的一点备忘
查看>>
CentOS 7下配置本地yum源及yum客户端
查看>>
Mybatis中的collection、association来处理结果映射
查看>>
如何对 GIT 分支进行规划? (转)
查看>>
浅谈简单工作流设计——责任链模式配合策略与命令模式的实现
查看>>
HDOJ(HDU) 1406 完数
查看>>
gradle项目中资源文件的相对路径打包处理技巧
查看>>
让手机支持OTG,不看绝对后悔! - 我也做一回搬运工,解决RFID读卡器OTG支持问题...
查看>>
Hadoop-2.7.0 HDFS DataXceiverServer两个参数的疑问
查看>>
linux exec函数家族
查看>>
几种软负载均衡策略分析
查看>>
.net——序列化与反序列化中对日期时间的处理
查看>>
独家揭露网站内链建设seo优化的科学方法
查看>>
MVVM 模式介绍
查看>>
.NET Core采用的全新配置系统[10]: 配置的同步机制是如何实现的?
查看>>
阿里云AI首席科学家闵万里:让萧山救护车等待时间至少降低50%,“城市大脑”是如何做到的...
查看>>
《Linux From Scratch》第二部分:准备构建 第四章:最后的准备- 4.2. 创建 $LFS/tools 文件夹...
查看>>
再谈数据外泄和数据库安全
查看>>
Java 程序优化:字符串操作、基本运算方法等优化策略
查看>>
[ASP.NET MVC]通过对HtmlHelper扩展简化“列表控件”的绑定
查看>>