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

什么是异步编程

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

异步编程实现

在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 int AddDel(int x, int y);
 5 
 6 /// <summary>
 7 /// 任务类
 8 /// </summary>
 9 public class TaskClass
10 {
11     //计算任务
12     public static int AddTask(int x, int y)
13     {
14         Console.WriteLine("异步线程(ThreadId = {0})开始执行计算任务.\n", Thread.CurrentThread.ManagedThreadId);
15 
16         Console.WriteLine("异步线程(ThreadId = {0})计算中...\n", Thread.CurrentThread.ManagedThreadId);
17 
18         Thread.Sleep(3000);
19 
20         int result = x + y;
21 
22         Console.WriteLine("异步线程(ThreadId = {0})结束执行计算任务.\n", Thread.CurrentThread.ManagedThreadId);
23 
24         return result;
25     }
26 }
27    
28 /// <summary>
29 /// 实现异步编程,主线程不会阻塞
30 /// </summary>
31 public class AsynCallbackClass
32 {
33     public static int result;
34 
35     public static void Main(string[] args)
36     {
37         Console.WriteLine("主线程(ThreadId = {0})开始执行.\n", Thread.CurrentThread.ManagedThreadId);
38 
39         AddDel addDel = new AddDel(TaskClass.AddTask);
40 
41         int x = 123457, y = 48759;
42 
43         Console.WriteLine("主线程(ThreadId = {0})调用BeginInvoke()方法开始执行异步操作.\n", Thread.CurrentThread.ManagedThreadId);
44 
45         //开始执行异步操作,Callback为定义的回调方法.
46         addDel.BeginInvoke(x, y, Callback, null);
47 
48         Console.WriteLine("主线程(ThreadId = {0})继续执行...\n", Thread.CurrentThread.ManagedThreadId);
49 
50         Thread.Sleep(5000);
51 
52         //输出计算任务返回的结果
53         Console.WriteLine("计算结果:{0} + {1} = {2}.\n", x, y, result);
54 
55         Console.WriteLine("主线程(ThreadId = {0})执行结束.\n", Thread.CurrentThread.ManagedThreadId);
56     }
57 
58     /// <summary>
59     /// 回调方法
60     /// </summary>
61     /// <param name="ar"></param>
62     public static void Callback(IAsyncResult ar)
63     {
64         AsyncResult asyncResult = ar as AsyncResult;
65 
66         if (asyncResult == null) { return; }
67 
68         AddDel addDel = asyncResult.AsyncDelegate as AddDel;
69 
70         if (addDel == null) { return; }
71 
72         Console.WriteLine("回调方法中调用EndInvoke()方法结束执行异步操作,获取计算任务结果.\n", Thread.CurrentThread.ManagedThreadId);
73 
74         //结束执行异步操作,并返回计算任务结果.
75         result = addDel.EndInvoke(ar);
76     }
77 }

运行结果:

使用C#委托来实现异步编程 数据库 第1张

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

总结

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

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