多线程编程之 ---线程间通讯



下载源代码



七、线程通讯

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

  1. 使用全局变量进行通信

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

  2. 使用自定义消息

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

例程7 MultiThread7

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

  1. 建立一个基于对话框的工程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,属性选中“边框”;
  2. 在MultiThread7Dlg.h中定义如下变量:
    protected:
    	int nAddend;

    代表加数的大小。

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

    void CMultiThread7Dlg::OnRadio1()
    {
    	nAddend=10;
    }
    
    void CMultiThread7Dlg::OnRadio2()
    {
    	nAddend=50;
    
    }
    
    void CMultiThread7Dlg::OnRadio3()
    {
    	nAddend=100;
    
    }

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

    BOOL CMultiThread7Dlg::OnInitDialog()
    {
    ……
    	((CButton*)GetDlgItem(IDC_RADIO1))->SetCheck(TRUE);
    	nAddend=10;
    ……

    在MultiThread7Dlg.h中添加:

    #include "CalculateThread.h"
    #define WM_DISPLAY WM_USER+2
    class CMultiThread7Dlg : public CDialog
    {
    // Construction
    public:
    	CMultiThread7Dlg(CWnd* pParent = NULL);	// standard constructor
    	CCalculateThread* m_pCalculateThread;
    ……
    protected:
    	int nAddend;
    	LRESULT OnDisplay(WPARAM wParam,LPARAM lParam);
    ……

    在MultiThread7Dlg.cpp中添加:

    BEGIN_MESSAGE_MAP(CMultiThread7Dlg, CDialog)
    ……
    	ON_MESSAGE(WM_DISPLAY,OnDisplay)
    END_MESSAGE_MAP()
    
    LRESULT CMultiThread7Dlg::OnDisplay(WPARAM wParam,LPARAM lParam)
    {
    	int nTemp=(int)wParam;
    	SetDlgItemInt(IDC_STATUS,nTemp,FALSE);
    
      return 0;
    
    }

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

  3. 双击按钮IDC_SUM,添加消息响应函数:
    void CMultiThread7Dlg::OnSum()
    {
    	m_pCalculateThread=
    		(CCalculateThread*)AfxBeginThread(RUNTIME_CLASS(CCalculateThread));
    
    	Sleep(500);
    
    	m_pCalculateThread->PostThreadMessage(WM_CALCULATE,nAddend,NULL);
    }

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

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

    在文件CalculateThread.h 中添加

    #define WM_CALCULATE WM_USER+1
    class CCalculateThread : public CWinThread
    {
    ……
    protected:
    	afx_msg LONG OnCalculate(UINT wParam,LONG lParam);
    ……

    在文件CalculateThread.cpp中添加

    LONG CCalculateThread::OnCalculate(UINT wParam,LONG lParam)
    {
    	int nTmpt=0;
    	for(int i=0;i<=(int)wParam;i++)
    	{
    		nTmpt=nTmpt+i;
    	}
    
    	Sleep(500);
        ::PostMessage((HWND)(GetMainWnd()->GetSafeHwnd()),WM_DISPLAY,nTmpt,NULL);
    
    	return 0;
    }
    BEGIN_MESSAGE_MAP(CCalculateThread, CWinThread)
    	//{{AFX_MSG_MAP(CCalculateThread)
    		// NOTE - the ClassWizard will add and remove mapping macros here.
    	//}}AFX_MSG_MAP
    	ON_THREAD_MESSAGE(WM_CALCULATE,OnCalculate)
    //和主线程对比,注意它们的区别
    END_MESSAGE_MAP()

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

    #include "MultiThread7Dlg.h"

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

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

(未完待续)

文章转自:http://www.blogchinese.com/?uid-46225-action-viewspace-itemid-1244408

时间: 2024-08-31 21:15:50

多线程编程之 ---线程间通讯的相关文章

多线程编程之三——线程间通讯

七.线程间通讯 一般而言,应用程序中的一个次要线程总是为主线程执行特定的任务,这样,主线程和次要线程间必定有一个信息传递的渠道,也就是主线程和次要线程间要进行通信.这种线程间的通信不但是难以避免的,而且在多线程编程中也是复杂和频繁的,下面将进行说明. 使用全局变量进行通信 由于属于同一个进程的各个线程共享操作系统分配该进程的资源,故解决线程间通信最简单的一种方法是使用全局变量.对于标准类型的全局变量,我们建议使用volatile 修饰符,它告诉编译器无需对该变量作任何的优化,即无需将它放到一个寄

线程间通讯-Java写交易客户端(多线程、对象数据传送等简单问题)

问题描述 Java写交易客户端(多线程.对象数据传送等简单问题) 有如下几个类: 1.Ticker类//此Ticker为简单java类,其属性与服务器传来的json字段对应,通过Decoder类反系列化json//反系列化以后的数据,用以做逻辑判断,符合逻辑,则向服务器发出某种请求 public class Ticker implements Serializable { private static final long serialVersionUID = 2015022601L; priv

Java线程间通讯概述

这个故事源自一个很简单的想法:创建一个对开发人员友好的.简单轻量的线程间通讯框架,完全不 用锁.同步器.信号量.等待和通知,在Java里开发一个轻量.无锁的线程内通讯框架:并且也没有队列 .消息.事件或任何其他并发专用的术语或工具. 只用普通的老式Java接口实现POJO的通讯. 它可能跟Akka的类型化actor类似,但作为一个必须超级轻量,并且要针对单台多核计算机进行优化的 新框架,那个可能有点过了. 当actor跨越不同JVM实例(在同一台机器上,或分布在网络上的不同机器上)的进程边界时,

vc-【求助】VC++ 类间/线程间通讯问题

问题描述 [求助]VC++ 类间/线程间通讯问题 遇到这样一个问题,有两个类,一个为窗口类,一个为数据处理类.窗口中按下按钮后会启动两个线程,一个线程使数据处理类中的函数开始运行,另一个使进度条控件运行.数据处理类的函数需要在运行中不断将运行的结果传递给进度条的线程,请问该如何实现? 解决方案 两个线程之间的消息可以通过 PostThreadMessage 来传递. 解决方案二: 线程创建消息循环,CWinThread,然后可以通过PostThreadMessage来发送消息,接收到在消息循环中

vc 基于对话框多线程编程实例——线程之间的通信

 vc基于对话框多线程编程实例--线程之间的通信 实例:  

C#多线程编程实例 线程与窗体交互

C#多线程编程实例 线程与窗体交互 代码: public partial class Form1 : Form { //声明线程数组 Thread[] workThreads = new Thread[10]; public Form1() { InitializeComponent(); } //此委托允许异步的调用为Listbox添加Item delegate void AddItemCallback(string text); //这种方法演示如何在线程安全的模式下调用Windows窗体上

多线程编程之四 ---线程的同步

下载源代码 八.线程的同步 虽然多线程能给我们带来好处,但是也有不少问题需要解决.例如,对于像磁盘驱动器这样独占性系统资源,由于线程可以执行进程的任何代码段,且线程的运行是由系统调度自动完成的,具有一定的不确定性,因此就有可能出现两个线程同时对磁盘驱动器进行操作,从而出现操作错误:又例如,对于银行系统的计算机来说,可能使用一个线程来更新其用户数据库,而用另外一个线程来读取数据库以响应储户的需要,极有可能读数据库的线程读取的是未完全更新的数据库,因为可能在读的时候只有一部分数据被更新过. 使隶属于

c#.net多线程编程教学——线程同步_C#教程

随着对多线程学习的深入,你可能觉得需要了解一些有关线程共享资源的问题. .NET framework提供了很多的类和数据类型来控制对共享资源的访问. 考虑一种我们经常遇到的情况:有一些全局变量和共享的类变量,我们需要从不同的线程来更新它们,可以通过使用System.Threading.Interlocked类完成这样的任务,它提供了原子的,非模块化的整数更新操作. 还有你可以使用System.Threading.Monitor类锁定对象的方法的一段代码,使其暂时不能被别的线程访问. System

C#中使用多线程编程之线程池

编程|多线程 1.     引言 近来在研究C#多线程编程碰到了线程池的概念.不懂,我搜,于是在MSDN和CSDN上寻寻觅觅一番终于搞明白,"缘"来如此,安装本人理解修改后写下这篇文章,希望对后来者有所帮助.   2.     线程池的概念 可以使用线程池来根据应用程序的需要更为有效地利用多个线程.许多应用程序使用多个线程,但这些线程经常在休眠状态中耗费大量的时间来等待事件发生,编程者手动管理多个线程也是一件比较麻烦的事情.事实上,使用线程池就是为应用程序提供一个由系统管理的辅助线程池