C#线程系列(1)：BeginInvoke和EndInvoke方法_c# begininvoke回调-程序员宅基地

技术标签： C#

一、线程概述

在操作系统中一个进程至少要包含一个线程，然后，在某些时候需要在同一个进程中同时执行多项任务，或是为了提供程序的性能，将要执行的任务分解成多个子任务执行。这就需要在同一个进程中开启多个线程。我们使用 C# 编写一个应用程序（控制台或桌面程序都可以），然后运行这个程序，并打开 windows 任务管理器，这时我们就会看到这个应用程序中所含有的线程数，如下图所示。

如果任务管理器没有“线程数”列，可以【查看】>【选择列】来显示“线程计数”列。从上图可以看出，几乎所有的进程都拥有两个以上的线程。从而可以看出，线程是提供应用程序性能的重要手段之一，尤其在多核CPU的机器上尤为明显。

二、用委托(Delegate)的BeginInvoke和EndInvoke方法操作线程

在C#中使用线程的方法很多，使用委托的BeginInvoke和EndInvoke方法就是其中之一。BeginInvoke方法可以使用线程异步地执行委托所指向的方法。然后通过EndInvoke方法获得方法的返回值（EndInvoke方法的返回值就是被调用方法的返回值），或是确定方法已经被成功调用。我们可以通过四种方法从EndInvoke方法来获得返回值。

三、直接使用EndInvoke方法来获得返回值

当使用 BeginInvoke 异步调用方法时，如果方法未执行完， EndInvoke 方法就会一直阻塞，直到被调用的方法执行完毕。如下面的代码所示：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace MyThread
{
     class Program
    {
         private static int newTask( int ms)
        {
            Console.WriteLine( " 任务开始 ");
            Thread.Sleep(ms);
            Random random = new Random();
             int n = random.Next( 10000);
            Console.WriteLine( " 任务完成 ");
             return n;
        }

         private delegate int NewTaskDelegate( int ms);


         static void Main( string[] args)
        {
            NewTaskDelegate task = newTask;
            IAsyncResult asyncResult = task.BeginInvoke( 2000, null, null);

            // EndInvoke方法将被阻塞2秒
             int result = task.EndInvoke(asyncResult);
            Console.WriteLine(result);
        }
    }
}

在运行上面的程序后，由于newTask方法通过Sleep延迟了2秒，因此，程序直到2秒后才输出最终结果（一个随机整数）。如果不调用EndInvoke方法，程序会立即退出，这是由于使用BeginInvoke创建的线程都是后台线程，这种线程一但所有的前台线程都退出后（其中主线程就是一个前台线程），不管后台线程是否执行完毕，都会结束线程，并退出程序。关于前台和后台线程的详细内容，将在后面的部分讲解。

读者可以使用上面的程序做以下实验。首先在Main方法的开始部分加入如下代码：

Thread.Sleep(10000);

以使Main方法延迟10秒钟再执行下面的代码，然后按Ctrl+F5运行程序，并打开企业管理器，观察当前程序的线程数，假设线程数是4，在10秒后，线程数会增至5，这是因为调用BeginInvoke方法时会建立一个线程来异步执行newTask方法，因此，线程会增加一个。

四、使用IAsyncResult asyncResult属性来判断异步调用是否完成

虽然上面的方法可以很好地实现异步调用，但是当调用 EndInvoke 方法获得调用结果时，整个程序就象死了一样，这样做用户的感觉并不会太好，因此，我们可以使用 asyncResult 来判断异步调用是否完成，并显示一些提示信息。这样做可以增加用户体验。代码如下：

static void Main( string[] args)
{
    NewTaskDelegate task = newTask;
    IAsyncResult asyncResult = task.BeginInvoke( 2000, null, null);

     while (!asyncResult.IsCompleted)
    {
        Console.Write( " * ");
        Thread.Sleep( 100);
    }
     // 由于异步调用已经完成，因此， EndInvoke会立刻返回结果
    int result = task.EndInvoke(asyncResult);
    Console.WriteLine(result);
}

上面代码的执行结果如下图所示。

由于是异步，所以“*”可能会在“任务开始”前输出，如上图所示。

五、使用WaitOne方法等待异步方法执行完成

使用 WaitOne 方法是另外一种判断异步调用是否完成的方法。代码如下：

static void Main( string[] args)
{
    NewTaskDelegate task = newTask;
    IAsyncResult asyncResult = task.BeginInvoke( 2000, null, null);

     while (!asyncResult.AsyncWaitHandle.WaitOne( 100, false))
    {
         Console.Write( " * ");
    }

     int result = task.EndInvoke(asyncResult);
    Console.WriteLine(result);
}

WaitOne的第一个参数表示要等待的毫秒数，在指定时间之内，WaitOne方法将一直等待，直到异步调用完成，并发出通知，WaitOne方法才返回true。当等待指定时间之后，异步调用仍未完成，WaitOne方法返回false，如果指定时间为0，表示不等待，如果为-1，表示永远等待，直到异步调用完成。

六、使用回调方式返回结果

上面介绍的几种方法实际上只相当于一种方法。这些方法虽然可以成功返回结果，也可以给用户一些提示，但在这个过程中，整个程序就象死了一样（如果读者在 GUI 程序中使用这些方法就会非常明显），要想在调用的过程中，程序仍然可以正常做其它的工作，就必须使用异步调用的方式。下面我们使用 GUI 程序来编写一个例子，代码如下：

private delegate int MyMethod();
private int method()
{
    Thread.Sleep( 10000);
     return 100;
}
private void MethodCompleted(IAsyncResult asyncResult)
{
     if (asyncResult == null) return;
    textBox1.Text = (asyncResult.AsyncState as
    MyMethod).EndInvoke(asyncResult).ToString();
}

private void button1_Click( object sender, EventArgs e)
{

    MyMethod my = method;
    IAsyncResult asyncResult = my.BeginInvoke(MethodCompleted, my);
}

要注意的是，这里使用了BeginInvoke方法的最后两个参数（如果被调用的方法含有参数的话，这些参数将作为BeginInvoke的前面一部分参数，如果没有参数，BeginInvoke就只有两个参数了）。第一个参数是回调方法委托类型，这个委托只有一个参数，就是IAsyncResult,如MethodCompleted方法所示。当method方法执行完后，系统会自动调用MethodCompleted方法。BeginInvoke的第二个参数需要向MethodCompleted方法中传递一些值，一般可以传递被调用方法的委托，如上面代码中的my。这个值可以使用IAsyncResult.AsyncState属性获得。

由于上面的代码通过异步的方式访问的form上的一个textbox，因此，需要按ctrl+f5运行程序（不能直接按F5运行程序，否则无法在其他线程中访问这个textbox，关于如果在其他线程中访问GUI组件，并在后面的部分详细介绍）。并在form上放一些其他的可视控件，然在点击button1后，其它的控件仍然可以使用，就象什么事都没有发生过一样，在10秒后，在textbox1中将输出100。

七、其他组件的BeginXXX和EndXXX方法

在其他的.net组件中也有类似BeginInvoke和EndInvoke的方法，如System.Net.HttpWebRequest类的BeginGetResponse和EndGetResponse方法，下面是使用这两个方法的一个例子：

private void requestCompleted(IAsyncResult asyncResult)
{
     if (asyncResult == null) return;
    System.Net.HttpWebRequest hwr = asyncResult.AsyncState as System.Net.HttpWebRequest;
    System.Net.HttpWebResponse response =
(System.Net.HttpWebResponse)hwr.EndGetResponse(asyncResult);
    System.IO.StreamReader sr = new
System.IO.StreamReader(response.GetResponseStream());
    textBox1.Text = sr.ReadToEnd();
}
private delegate System.Net.HttpWebResponse RequestDelegate(System.Net.HttpWebRequest request);

private void button1_Click( object sender, EventArgs e)
{
    System.Net.HttpWebRequest request =
    (System.Net.HttpWebRequest)System.Net.WebRequest.Create( " http://www.cnblogs.com ");
    IAsyncResult asyncResult =request.BeginGetResponse(requestCompleted, request);
}

本文链接：https://blog.csdn.net/yaokang522/article/details/49336801

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

集合知识（一）：集合的整体认识_傻露的大天才的博客-程序员宅基地

集合知识（一）：集合的整体认识1.集合的简单介绍集合：简而言之就是一种存储数据的容器，包括集合的接口，实现类，以及算法。接口：规定了整个集合的顶层框架，常用的API的规范，相当于给整个集合制定了标准，实现了接口的，都可以看作集合，这也是Java多态思想的体现。实现类：就是对接口中的方法的具体的实现，相当于根据接口制定的标准的具体实现。算法：算法存在于实现类中，是对接口中规定的ApI的实现过程，这里是集合的精髓，也是集合强大的原因，这些算法方便了我们的程序开发。2.集合的体系原则简而言之，集合的

ERROR o.s.b.SpringApplication - [reportFailure,835] - Application run failed_10:24:18.251 [main] error o.s.b.springapplication _谢十亿的博客-程序员宅基地

ERROR o.s.b.SpringApplication - [reportFailure,835] - Application run failed_10:24:18.251 [main] error o.s.b.springapplication - [reportfailure,830] - ap

编译对应ARM平台的QT的mysql驱动-程序员宅基地

虚拟机版本：UBUNTU 11.10 交叉编译器：友善的4.5.1 QT版本：4.7.0 mysql版本：5.1.16开发板：Tiny6410说实话编译arm版本QT的mysql驱动真是纠结啊，看了大部分资料就没有一个讲全的，最后仔细想了下就想出来了。先讲讲我遇到的问题：1.开始自己编译qt

网络BD ring及注意事项_txbd->status=0x8800-程序员宅基地

Copyright (C) 2009 Dave Liu, All rights reserved.[*** BD - buffer descriptor***]Basically, most DMA engine of network interface use the buffer descriptors likely structure to exchange the data between_txbd->status=0x8800

关于SpringBoot JPA的deleteById方法报错问题_jpa deletebyid不存在_嗎嗎的博客-程序员宅基地

记录错误的处理方法1、只需在MyRepository接口中的deleteById方法上加上事务注解即可@Transactionalpublic interface StudentRepository extends JpaRepository<Student, Integer> { @Transactional void deleteById(int id);}..._jpa deletebyid不存在

Rancher2+Docker+SpringCloud+Jenkins+Redis集群+MySQL主从搭建（四）CentOs7 安装Jenkins_jenkins rancher2-程序员宅基地

CentOs7 安装Jenkins通过Rancher部署服务来完成jenkins的安装下载镜像在rancher的部署页中做如下操作出现active说明启动成功通过Rancher部署服务来完成jenkins的安装下载镜像当然，从rancher的部署页中启动可以自动为我们下载部署的镜像但我们这里为了更清晰的使用，采用手动pull镜像的方式，执行如下命令：docker pull jenkins/jenkins:alpine当然如果你有镜像提供者的Dockerfile那就更好了有了Dockerfile_jenkins rancher2

随便推点

Java 执行命令并读取缓冲区内容-程序员宅基地

try { Process process = Runtime.getRuntime().exec("sh /home/test.sh"); BufferedReader inr = new BufferedReader(new InputStreamReader(process.getInputStream(),"GBK")); String line = null; while ((line...

货物出库管理信息系统-程序员宅基地

出自 MBA智库百科(http://wiki.mbalib.com/)[编辑]什么是货物出库管理信息系统　　货物出库管理信息系统是物流配送中心重要的信息系统之一，它对外作业主要是从客户取得货物订单，然后按客户订货要求进行订单处理、分拣、组配、发货到实际将

结构体使用方法大全（定义，内存大小，初始化，结构数组，结构指针，位域，结构和联合体的嵌套，结构体包含函数指针）_结构体类型的定义及所占内存的字节数-程序员宅基地

结构体使用方法大全（定义，内存大小，初始化，结构数组，结构指针，位域，结构和联合体的嵌套，结构体包含函数指针） “结构”是一种构造类型,它是由若干“成员”组成的。每一个成员可以是一个基本数据类型或者又是一个构造类型。结构既是一种“构造”而成的数据类型,那么在说明和使用之前必须先定义它,也就是构造它。如同在说明和调用函数之前要先定义函数一样。一、结构的定义说明结构变量有以下三种方法。先定义结构,再说明结构变量。如:struct stu{int num;char name[20_结构体类型的定义及所占内存的字节数

从Java EE到Jakarta EE，企业版Java的发展历程（建议收藏）_退休的汤姆的博客-程序员宅基地

前言诞生于1985年的Java语言，早已年过三旬，甚至已经越过“35岁魔咒”，比很多同学的年龄大得多。正所谓三十年河东，三十年河西，有人说Java已廉颇老矣，基本结构过于老套不灵活，但显示情况是它“老而不死”依旧常年霸榜，是棵常青树。深爱Java的同学知道，Java并不老（Python年纪更大）、开发效率并不低（马拉松型选手看中长远效率）、语法并不是啰嗦（这是严谨的表现，同时也拥抱了Stream流式、Function函数式编程来简化开发）。Java鼓励用严谨的方法、正确的方式来设置内容，这让Jav_jakarta ee

delphi 编写PCM播放器_delphi 音频流播放-程序员宅基地

delphi 编写PCM播放器本类支持对wav,pcm文件的本地播放，以及pcm网络流播放。unit uSound;interface uses WINDOWS,DirectSound, MMSystem,classes,ActiveX;const WAV_SAMPLE_RATE=44100; //PCM sample rate WAV_CHANNEL_NUMBER=1; ..._delphi 音频流播放

关于axios文件上传（csv）出现得问题及解决方法_文件上传csv文件跨域错误,xlsx不存在错误-程序员宅基地

在开发前端vue项目是遇到一个批量导入（导入表格csv）功能，前端框架统一使用用axios发的请求，所以就不加思索得就用的axios请求。由于后端接收上传的scv文件，需要请求头为“multiple/form-data”，所以单独用axios.create,单独做了给上传文件的配置：import qs from 'qs'import axios from "axios"const ..._文件上传csv文件跨域错误,xlsx不存在错误