使用C#委托来实现异步编程
2018-06-23 23:57:44来源:未知 阅读 ()
最近在我参与的几个.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 }
运行结果:
从运行结果中,我们可以发现主线程在调用了BeginInvoke()方法后,没有阻塞,而是继续向下执行,而且任务也确实由一个新的线程来执行,任务执行结束后,调用回调方法,在回调方法中调用EndInvoke()方法来获取任务执行结果。
总结
1. 在异步编程中,当前线程是不会被阻塞的。
2. C#的委托机制可以很方便地实现异步编程。
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
上一篇:中间件(2)消息队列
下一篇:C#输出杨辉三角形
- CSS中的float和margin的混合使用 2020-06-11
- 使用 Apache SSI(Server Side Includes) 制作多语言版静态网 2020-06-01
- position: sticky实现导航栏下滑吸顶效果 2020-05-30
- 通配符选择器 2020-05-27
- ECharts安装与使用 2020-05-26
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash