C#.NET：浅述.Net的异步机制(委托Delegate) - 上篇

本文转载自查看原文 2013-07-16 09:00 1127 多线程/ .net/ 程序池/ C#语法基础/ Invoke/ 委托/ 异步机制

在阅读下面知识前,我已经认为你已经具有c#的基础,包括简单的委托知识; 代码使用VS2008开发,但是会在.Net Framework 2.0(C Sharp)编写

什么是.Net异步机制呢?

　　在解释这个话题前，我们先看看同步的程序，就是我们常用的Hello World 程序。

Code 1:

 1 class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             // 查看当前的线程ID, 是否线程池里面的线程
 6             Console.WriteLine("1,Thread ID:#{0},Is PoolThread?{1}", 
 7 Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
 8 
 9             AsyncTest test = new AsyncTest();
10             string val = test.Hello("Andy Huang");
11 
12             Console.WriteLine(val);
13             Console.ReadLine(); // 让黑屏等待,不会直接关闭..
14         }
15     }
16 
17     public class AsyncTest
18     {
19         public string Hello(string name)
20         {
21             // 查看当前的线程ID, 是否线程池里面的线程
22             Console.WriteLine("2,Thread ID:#{0},Is PoolThread?{1}", 
23 Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
24             return "Hello:" + name;
25         }
26     }

图1

　　我们可以从图1看出,我们平常写的Hello 程序是同一个线程的,而且不是线程池理的线程程序。按照上面的程序稍做改动, 那么开始我们第一个异步的Hello World 程序。

　　使用.Net 的委托机制来为我们的程序提供异步操作行为。

　　1步, 为我们的AsyncTest(Hello方法) 声明一个委托

　　public delegate string AsyncEventHandler(string name)；

　　2步,使用委托提供的BeginInvoke, EndInvoke 方法(具体使用下一篇文章详细介绍)来提供异步的调用。

string val = test.Hello("Andy Huang");

修改为

AsyncEventHandler async = test.Hello;

IAsyncResult result = async.BeginInvoke("Andy Huang", null, null);

string val = async.EndInvoke(result);

下面是完整的代码：

 1 class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             // 查看当前的线程ID, 是否线程池里面的线程
 6             Console.WriteLine("1,Thread ID:#{0},Is PoolThread?{1}", 
 7 Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
 8 
 9             AsyncTest test = new AsyncTest(); 
10             //把Hello 方法分配给委托对象
11             AsyncEventHandler async = test.Hello; //注释1,建议用=,不用+=
12 
13             //发起一个异步调用的方法,赋值"Andy Huang", 返回IAsyncResult 对象
14             IAsyncResult result = async.BeginInvoke("Andy Huang", null, null);
15 
16             //这里会阻碍线程,直到方法执行完毕
17             string val = async.EndInvoke(result);
18 
19             Console.WriteLine(val);
20             Console.ReadLine(); // 让黑屏等待,不会直接关闭..
21         }
22     }
23 
24     //我们使用委托来提供.Net的异步机制
25     public delegate string AsyncEventHandler(string name);
26     public class AsyncTest
27     {
28         public string Hello(string name)
29         {
30             // 查看当前的线程ID, 是否线程池里面的线程
31             Console.WriteLine("2,Thread ID:#{0},Is PoolThread?{1}", 
32 Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
33             return "Hello:" + name;
34         }
35     }

注释1: 用=操作符在于分配委托对象时候不需要初始化;并且异步调用时候只能有一个目标方法.

图2

　　对比图1 和图2, ,可以看出(2,Thread ID:#10,Is PoolThread?True),在使用异步机制的时候,其实就是开启一个新的线程来执行我们的方法,并且这个线程来自线程堆. 到这里,我们就很好的解释了”什么是.Net异步机制?”

说到这里,结束了吗? 可能大家会想其实使用异步就是多了个委托( public delegate string AsyncEventHandler(string name);) 那么到底为我们做了些什么呢?

　　通过反编译(微软提供的IL Disassembler)我们看到：

图3

编译器为我们生成了下面类定义(其实委托就是一个类)

public sealed class AsyncEventHandler : MulticastDelegate

    {

        public AsyncEventHandler(object @object, IntPtr method)

        {....}

        public virtual IAsyncResult BeginInvoke(string name, AsyncCallback callback, object @object)

        {...}

        public virtual string EndInvoke(IAsyncResult result)

        {...}

        public virtual string Invoke(string name)

        {...}

    }