博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
谈谈c#中异步编程模型的变迁
阅读量:4647 次
发布时间:2019-06-09

本文共 3294 字,大约阅读时间需要 10 分钟。

大家在编程过程中都会用到一些异步编程的情况。在c#的BCL中,很多api都提供了异步方法,初学者可能对各种不同异步方法的使用感到迷惑,本文主要为大家梳理一下异步方法的变迁以及如何使用异步方法。

BeginXXX,EndXXX模式

在.Net Framework 2.0中,最常见的方法是BeginXXX,和EndXXX这样的方法来搭配使用。这种模式可以概括为方法+回调方法模式或者称为InvokeMethod+EventHandler模式。

这种模型的基本流程是:

  1. 调用BeginXXX方法
  2. BeginXXX方法中传入一个回调方法,这个回调方法会在异步方法执行结束后被执行
  3. 调用EndXXX方法,使用EndXXX方法会阻塞当前线程,直到异步方法返回结果。

我们看一个FileStream的示例方法,在.Net 2.0中,你需要这样使用异步:

using System;using System.IO;using System.Text;public class AsyncTest{    public static void Main(string[] args)    {        using (FileStream file = new FileStream("Test.txt", FileMode.OpenOrCreate))        {            var bytes = Encoding.UTF8.GetBytes("Test for .net framework 2.0");            IAsyncResult asyncResult = file.BeginWrite(bytes, 0, bytes.Length, callback, null);            file.EndWrite(asyncResult);        }        Console.ReadLine();    }    private static void callback(IAsyncResult ar)    {        Console.WriteLine("Finish Write");    }}

XXXAsync模式

从.Net 4.0开始,微软引入了Task。由于Task本身的灵活性,也使得我们的异步编程模型更简洁。上面的例子在.Net 4.5中可以这样实现:

using System;using System.IO;using System.Text;using System.Threading.Tasks;public class AsyncTest{    public static void Main(string[] args)    {        using (FileStream file = new FileStream("Test.txt", FileMode.OpenOrCreate))        {            var bytes = Encoding.UTF8.GetBytes("Test for .net framework 4.5");            var task = file.WriteAsync(bytes, 0, bytes.Length);            task.Wait();        }        Console.ReadLine();    }}

微软在许多BCL的api中都添加了XXXAsync方法来实现新的异步模型。Task本身比回调方法灵活了许多,可以更优雅的实现回调,取消,调度等操作。关于Task的使用方式可以看我之前总结的文章。

async和await模型

为了进一步简化异步模型,微软从Visual Studio 2012开始引入了async和await关键字。这个模型本身是基于编译器的一个语法糖,编译后会生成一个statemachine模型。这样上面例子中的写法也可以简化成:

using System;using System.IO;using System.Text;using System.Threading.Tasks;public class AsyncTest{    public static void Main(string[] args)    {        TestFunc();    }    private static async void TestFunc()    {        using (FileStream file = new FileStream("Test.txt", FileMode.OpenOrCreate))        {            var bytes = Encoding.UTF8.GetBytes("Test for .net framework 4.5");            await file.WriteAsync(bytes, 0, bytes.Length);        }    }}

关于异步编程模型的兼容性

如果大家注意看BCL中的类库,会发现微软并没有在最新版本的类库中对每一个BeginXXX的方法都添加了XXXAsync方法。这种情况下我们如何能让新的异步模型兼容旧的方法呢?

以NamedPipeServerStream为例,这个类库实现了一个管道的功能,微软并没有为其更新XXXAsync方法,你可以使用TaskFactory来兼容新的异步模型,你可以这样来实现:

private static void OldAsyncModel()    {        NamedPipeServerStream pipe = new NamedPipeServerStream("customPipe", PipeDirection.InOut, -1, PipeTransmissionMode.Message, PipeOptions.Asynchronous | PipeOptions.WriteThrough);        IAsyncResult async = pipe.BeginWaitForConnection(callback, null);        pipe.EndWaitForConnection(async);    }    private static async void NewAsyncModel()    {        NamedPipeServerStream pipe = new NamedPipeServerStream("customPipe", PipeDirection.InOut, -1, PipeTransmissionMode.Message, PipeOptions.Asynchronous | PipeOptions.WriteThrough);        await Task.Factory.FromAsync(pipe.BeginWaitForConnection, pipe.EndWaitForConnection, null);    }

  

因此,我们可以总结为,.Net中有两种异步编程模型:

  1. 不返回Task对象的调用方法+回调方法的模型
  2. 返回Task对象的XXXAsync模型,和async,await模型

BeginXXX模型微软已经逐渐的考虑废弃,返回Task的异步编程模型目前是微软建议的方式。

  

作者:
出处:
本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。

转载于:https://www.cnblogs.com/myprogram/p/4972628.html

你可能感兴趣的文章
科学计算三维可视化---Mayavi入门(Mayavi库的基本元素和绘图实例)
查看>>
python学习笔记-问题
查看>>
您对无法重新创建的表进行了更改或者启用了“阻止保存要求重新创建表的更改”选项【转】...
查看>>
生理周期
查看>>
(蓝桥杯)第八届A组C/C++方格分割
查看>>
react 版的知乎日报
查看>>
使用CSS3制作漂亮的按钮
查看>>
sql server 2014登录账号
查看>>
使用OutputDebugString输出调试信息
查看>>
leetcode 之Candy(12)
查看>>
kv.go
查看>>
利用截取字符串,生成已声明的字符串中的4位随机验证码。
查看>>
Spring 事务模型
查看>>
【MM系列】SAP S/4 HANA BP创建客户/供应商的一点想法
查看>>
【HANA系列】SAP HANA XS使用JavaScript数据交互详解
查看>>
【HANA系列】SAP HANA SQL获取上周的周一
查看>>
对称矩阵
查看>>
轮播图笔记!
查看>>
值类型与引用类型
查看>>
This kernel requires an x86-64 CPU, but only detected an i686 CPU.
查看>>