C#实现异步编程_.NET_编程开发_程序员俱乐部

最近在我参与的几个.Net项目中都有用到异步编程，作为一名.Net小白，很有必要好好地学习一下C#异步编程。

什么是异步

异步指的就是不用阻塞当前线程来等待任务的完成，而是将任务扔到线程池中去执行，当前线程可以继续向下执行，直至其它线程将任务完成，并回调通知当前线程。整个任务从开始到结束都是异步完成的，不会阻塞当前线程。因此，异步很重要的一点就是，不会阻塞当前线程。

实现异步编程

在C#语言中，主要是通过委托来实现异步编程的，在委托类型中定义了两个方法BeginInvoke()和EndInvoke()。

/// <summary>
/// 开始执行异步操作.
/// </summary>
/// <param name="param">委托方法的参数</param>
/// <param name="callback"></param>
/// <param name="object"></param>
/// <returns></returns>
IAsyncResult BeginInvoke(int param, AsyncCallback callback, Object @object);

/// <summary>
/// 结束执行异步操作，并且返回异步操作结果.
/// </summary>
/// <param name="result"></param>
/// <returns>委托方法的返回类型</returns>
string EndInvoke(IAsyncResult result);

下面就通过一段代码来具体实现异步编程

 1 /// <summary>
 2 /// 定义一个委托类型
 3 /// </summary>
 4 public delegate string Del();
 5 
 6 /// <summary>
 7 /// 任务类
 8 /// </summary>
 9 public class TaskClass
10 {
11     public static string SleepTask()
12     {
13         Console.WriteLine("异步线程(ThreadId = {0})开始执行睡眠任务，睡眠3s.\n", Thread.CurrentThread.ManagedThreadId);
14 
15         Thread.Sleep(3000);
16 
17         Console.WriteLine("异步线程(ThreadId = {0})苏醒，睡眠任务执行结束.\n", Thread.CurrentThread.ManagedThreadId);
18 
19         return "异步线程执行成功.\n";
20     }
21 }
22    
23 /// <summary>
24 /// 异步编程实现类（主线程不会阻塞）
25 /// </summary>
26 public class AsynCallbackClass
27 {
28     public static string result;
29 
30     public static void Main(string[] args)
31     {
32         Console.WriteLine("主线程(ThreadId = {0})开始执行.\n", Thread.CurrentThread.ManagedThreadId);
33 
34         Del del = new Del(TaskClass.SleepTask);
35 
36         Console.WriteLine("主线程(ThreadId = {0})调用BeginInvoke()方法执行异步任务.\n", Thread.CurrentThread.ManagedThreadId);
37 
38         //开始执行异步操作，TaskClass.SleepTask无参数，Callback为定义的回调方法.
39         del.BeginInvoke(Callback, null);
40 
41         Console.WriteLine("主线程(ThreadId = {0})继续执行.\n", Thread.CurrentThread.ManagedThreadId);
42 
43         Thread.Sleep(5000);
44 
45         //输出异步任务返回的结果
46         Console.WriteLine(result);
47 
48         Console.WriteLine("主线程(ThreadId = {0})执行结束.\n", Thread.CurrentThread.ManagedThreadId);
49     }
50 
51     /// <summary>
52     /// 回调方法
53     /// </summary>
54     /// <param name="ar"></param>
55     public static void Callback(IAsyncResult ar)
56     {
57         AsyncResult asyncResult = ar as AsyncResult;
58 
59         if (asyncResult == null) { return; }
60 
61         Del del = asyncResult.AsyncDelegate as Del;
62 
63         if (del == null) { return; }
64 
65         Console.WriteLine("回调方法中调用EndInvoke()方法，获取异步任务结果.\n", Thread.CurrentThread.ManagedThreadId);
66         
67         //结束执行异步操作，并返回异步任务结果.
68         result = del.EndInvoke(ar);
69     }
70 }

运行结果：

从运行结果中，我们可以发现主线程在调用了BeginInvoke()方法后，没有阻塞，而是继续向下执行，而且任务也确实由一个新的线程来执行，任务执行结束后，调用回调方法，在回调方法中调用EndInvoke()方法来获取任务执行结果。

总结

1. 在异步编程中，当前线程是不会被阻塞的。

2. C#的委托机制可以很方便地实现异步编程。