C#线程间通讯

using System;
using System.Text;
using System.Windows.Forms;
using System.Threading;

namespace 线程间通讯
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        //1.创建Invoke函数,大致如下:
        /// <summary>
        /// Delegate function to be invoked by main thread
        /// </summary>
        private void InvokeFun()
        {
            if (prgBar.Value < 100)
            {
                prgBar.Value = prgBar.Value + 1;
                button1.Text = prgBar.Value.ToString();
            }
            if (prgBar.Value == 100)
            {
                MessageBox.Show("完成", this.Text);
                prgBar.Value = 0;
            }
        }

//2.子线程入口函数:
        /// <summary>
        /// Thread function interface
        /// </summary>
        private void ThreadFun()
        {
            //Create invoke method by specific function
           MethodInvoker mi = new MethodInvoker( this.InvokeFun );
            for( int i = 0; i < 100; i++ )
            {
               this.BeginInvoke( mi );//让主线程去访问自己创建的控件.
                Thread.Sleep( 100 );//在新的线程上执行耗时操作.
            }
        }

//3. Begin from here
        private void button1_Click(object sender, EventArgs e)
        {         
            Thread thdProcess = new Thread(new ThreadStart(ThreadFun));
            thdProcess.Start();
        }
    }
}

在不做处理的情况下,如果子线程访问由主线程创建的控件时,系统都会报错,告诉我们线程间不能直接调用.因为不同的线程是在不同的内存空间中各自无干扰的并行运行着的.那么要怎么做才能让在子线程中访问到想要访问的控件呢?

其实,从上面的例子中可以看出,实现线程间通讯其实并不复杂.thdProcess.Start()以后,开始了一个新的线程,这个线程从入口函数ThreadFun()开始.下面就是问题的关键了:

代码中用到了MethodInvoker 委托,在MSDN中是这样描述它的:该委托可执行托管代码中声明为 void 且不接受任何参数的任何方法,在对控件的 Invoke 方法进行调用时或需要一个简单委托又不想自己定义时可以使用该委托。在这里它实际上就代表了InvokeFun()方法.
另一个重要的方法:BeginInvoke(Delegate) ,它表示在创建控件的基础句柄所在线程上异步执行指定委托。它可异步调用委托并且此方法立即返回。可以从任何线程(甚至包括拥有该控件句柄的线程)调用此方法。如果控件句柄尚不存在,则此方法沿控件的父级链搜索,直到它找到有窗口句柄的控件或窗体为止。这里就是通过这个异步调用来完成子线程对主线程上相应控件的访问的.

回头想想,是不是很简单的三步:创建并开始线程->指定委托方法->异步调用.

时间: 2024-11-08 12:45:14

C#线程间通讯的相关文章

iOS开发多线程-线程间通讯

一.NSThread 线程间的通讯 1 - (void)demoAboutNSThread 2 { 3 NSLog(@"demoAboutNSThread %@", [NSThread currentThread]); 4 NSThread * thread = [[NSThread alloc] initWithTarget:self selector:@selector(longTimeOperation) object:nil]; 5 [thread start]; 6 } 7

线程间通讯

线程间通讯:把一个线程中计算的结果传递到另一个线程中使用. 示例场景:子线程下载网络图片,回主线程更新UI. NSThread示例代码: 1 - (void)viewDidLoad { 2 [super viewDidLoad]; 3 4 // 子线程下载网络数据 5 [self performSelectorInBackground:@selector(downloadImage) withObject:nil]; 6 } 7 8 // 加载网络数据,耗时操作,在子线程中进行 9 - (voi

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

线程间通讯 一.NSThread 1.简单说明 ①线程间通信:在1个进程中,线程往往不是孤立存在的,多个线程之间需要经常进行通信 ②线程间通信的体现 1个线程传递数据给另1个线程 在1个线程中执行完特定任务后,转到另1个线程继续执行任务 ③线程间通信常用方法 // waitUntilDone的含义: // 如果传入的是YES: 那么会等到主线程中的方法执行完毕, 才会继续执行下面其他行的代码 // 如果传入的是NO: 那么不用等到主线程中的方法执行完毕, 就可以继续执行下面其他行的低吗 /* *

Java 线程间通讯

/* 线程间通讯: 多个线程在处理同一资源,但是任务却不同. */ package com.cwcec.test; class Input implements Runnable { Resource r; public Input(Resource r) { this.r = r; } public void run() { int x = 0; while(true) { synchronized (r) { if(x == 0) { r.name = "Mike"; r.sex

android线程间通讯

近来找了一些关于android线程间通信的资料,整理学习了一下,并制作了一个简单的例子. andriod提供了 Handler 和 Looper 来满足线程间的通信.例如一个子线程从网络上下载了一副图片,当它下载完成后会发送消息给主线程,这个消息是通过绑定在主线程的Handler来传递的. 在Android,这里的线程分为有消息循环的线程和没有消息循环的线程,有消息循环的线程一般都会有一个Looper,这个事android的新 概念.我们的主线程(UI线程)就是一个消息循环的线程.针对这种消息循

iOS开发-多线程-线程间通讯

iOS开发多线程篇—线程间的通信 一.简单说明 线程间通信:在1个进程中,线程往往不是孤立存在的,多个线程之间需要经常进行通信 线程间通信的体现 1个线程传递数据给另1个线程 在1个线程中执行完特定任务后,转到另1个线程继续执行任务 线程间通信常用方法 - (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait; - (void)performSelector:(SE

有多少人在面试时,被Java 如何线程间通讯,问哭了?

正常情况下,每个子线程完成各自的任务就可以结束了.不过有的时候,我们希望多个线程协同工作来完成某个任务,这时就涉及到了线程间通信了. 本文涉及到的知识点: thread.join(), object.wait(), object.notify(), CountdownLatch, CyclicBarrier, FutureTask, Callable 下面我从几个例子作为切入点来讲解下 Java 里有哪些方法来实现线程间通信. 如何让两个线程依次执行? 那如何让 两个线程按照指定方式有序交叉运行

Java 使用pipe进行线程间通讯

Thinking in Java 中的例子,两个线程Sender&Receiver使用pipe进行通讯.Pipe是一个阻塞队列,解决了"生产者-消费者"线程通讯的问题. 1 import java.io.IOException; 2 import java.io.PipedReader; 3 import java.io.PipedWriter; 4 import java.util.concurrent.ExecutorService; 5 import java.util.

线程间通讯(等待唤醒机制)

锁.whit(); //将线程丢进线程池,暂停运行. 锁.notify(); //唤醒线程池中的最先存入那个同锁线程 锁.notifyAll(); //唤醒线程池中所有的同锁线程 都使用在同步中,因为要对持有监视器(锁)的线程操作.所以要使用在同步中,因为只有同步才具有锁. 为什么这些操作线程的方法要定义Object类中因为这些方法在操作同步中线程时,都需要标识它们所操作线程持有的锁只有同一个锁上的被等待线程,可以被同一个锁上notify唤醒.不可以对不同锁中的线程进行唤醒. 也就是说,等待和唤