【.NET Core】异步编程模式

本文涉及的产品
应用实时监控服务-应用监控,每月50GB免费额度
应用实时监控服务-用户体验监控,每月100OCU免费额度
简介: 【.NET Core】异步编程模式

一、概述

.NET提供了执行异步操作的三种模式:

  • 基于任务的异步模式(TAP),该模式使用单一方法表示异步操作的开始和完成。TAP是在.NET Framework 4 中引入的,这是在.NET中进行异步编程的推荐方法。C#的async和await关键词和Await运算符为TAP添加了语言支持。
  • **基于事件的异步模式(EAP)**是提供异步行为的基于事件的旧模型。这种模式需要后缀为Async的方法,以及一个或多个事件,事件处理程序委托类型和EventArg派生类型。EAP是在.NET Framework2.0中引入的。建议新开发中不再使用这种模式。
  • 异步编程模型模式(APM)(也称为IAsyncResult模式),这是使用IAsyncResult接口提供异步行为的旧模型。在APM模式下,同步操作需要Begin和End方法。不建议新的开发使用此模式。


二、基于任务的异步模式(TAP)

在.NET中,基于任务的异步模式是建议用于新开发的异步设计模式。它是基于System.Threading.Tasks命名中的TaskTask<TResult>类型,这个类型用于表示异步操作。

2.1 TAP模式命名、参数和返回类型

TAP使用单个方法表示异步操作的开始和完成。这与异步编码模型(APMIAsyncReult)模式和基于事件的异步模式(EAP)形成对比。APM需要BeginEnd方法。EAP需要后缀为Async的方法,以及一个或多个事件,事件处理程序委托类型和EventArg派生类型。


TAP中的异步方法在返回类型

  • System.Threading.Tasks.Task
  • System.Threading.Tasks.Task<TResult>


具体返回类型取决于相应的同步方法返回的是void还是类型TResult

TAP异步方法参数

TAP方法的参数应与其同步对应方法的参数匹配,并应以相同顺序提供。但是,out和ref参数不受此规则的限制,并应完全避免。应该将通过out或ref参数返回的所有数据改为作为由TResult返回的Task<TResult>的一部分返回,且应使用元组或自定义数据结构来容纳多个值。即使TAP方法的同步对应项没有提供CancellationToken参数,也应考虑添加此参数。


2.2 TAP初始化异步操

基于TAP的异步方法可以同步完成少量工作,如在返回结果任务之前,验证自变量和启动异步操作。应将同步工作保持最小,以便异步方法可以快速返回。快速返回的原因包括:


可以从用户界面线程调用异步方法,因此,所有长期运行的同步工作可能会降低应用程序的响应能力。

可以同时启动多个异步方法,因此,在异步方法的同步部分中的任何长时间运行的工作都可以延迟其他异步操作的启动,从而减少并发的优点。


2.3 TAP如何编译

自.NET Framework 4.5起,任何归于async关键字的方法都被视为异步方法,并且编译器会执行必要的转换,以使用TAP异步实现方法。异步方法应返回System.Treading.Tasks.Task或System.Threading.Tasks.Task<TResult>对象。对于后者,函数的主体应该返回TResult,并且编译器确保此结果是通过生成的任务对象获得。同样,未在方法的主体中处理的任何异常都会被封装处理未输出任务并导致生成的任务结束以TaskStatus.Faulted状态结束。此规则的异常发生在OperationCanceledException未得到处理时,在这种情况下生成的任务以TaskStatus.Canceled状态结束。


2.4 手动生成TAP方法

手动实现TAP模式以更好的控制实现。编译器依赖从System.Threading.Tasks命名空间公开的公共外围应用和System.Runtime.CompilerServices命名空间中支持的类型。手动实现TAP,需要创建一个TaskCompletionSource<TResult>对象,执行异步操作,并在操作完成时,调用SetResult、SetException、SetCanceled方法或调用这些方法之一的Try版本。手动实现TAP方法时,需在所在表示的异步操作完成生成的任务。例如:

public static Task<int> ReadTask(this Stream stream,byte[] buffer,int offset,int count,object state)
{
   var tcs =new TaskCompletionSource<int>();
   stream.BeginRead(buffer,offset,count,resp=>{
       try
       {
           tcs.SetResult(stream.EndRead(resp));
       }
       catch(Exception ex){tcs.SetException(ex);}
   },state);
   return tcs.Task;
}

2.5 混合方法实现TAP

混合方法可以将核心逻辑委托给编译器。如果想验证编译器生成的异步方法之外的参数时,可能需要使用这种混合方法,以便异常可以转义到该方法的直接调用方而不是通过System.Threading.Tasks.Task对象被公开:

public Task<int> MethodAsync(string input)
{
    if(input==null) throw new ArgumentNullException("input");
    return MethodAsyncInternal(input);
}
private async Task<int> MethodAsyncInternal(string input)
{
    return value;
}


2.6 TAP中Await挂起执行

使用await关键字开异步等待Task和Task<TResult>对象。等待Task时,await表达式的返回类型为void。等待Task<TResult>时,await表达式的类型为TResult。await表达式必须出现在异步方法的正文内。


实际上,await 功能通过使用延续任务在任务上安装回叫。此回叫在挂起点恢复异步方法。 恢复异步方法时,如果等待的操作已成功完成且为Task<TResult>,返回的是TResult。如果等待的Task或Task<TResult>以Canceked状态结束。就会抛出OpetationCanceledException异常。如果等待的Task或Task<TResult>以Faulted状态结束,就会抛出导致它发生故障的异常。一个Task可能由于多个异常而出错,但只会传播一个异常。不过Task.Exception属性会返回包含所有错误AggregateException异常。


调用异步方法时,将同步执行函数的正文,直到遇见尚未完成的可等待实例上的第一个 await 表达式,此时调用返回到调用方。如果异步方法不返回void,将会返回Task或Task<TResult>对象,以表示正在进行的计算。在非void异常方法中,如果遇到return语句或到达方法正文末尾,任务就以RanToCompletion最终状态完成。如果未经处理的异常导致无法控制异步方法正文,任务就以Faulted状态结束。如果异常为OperationCanceledException,任务改为以Canceled状态结束。


2.7 TAP中使用Yield和ConfigureAwait配置挂起和恢复

使用Task.Yield方法,将暂停点引入异步方法。

Task.Run(async delegate{
   int flag=0;
    do{
        await Task.Yield();
        flag++;
    }while(flag<10000);
});

使用Task.ConfigureAwait方法,更好地控制异步方法中的暂停和恢复。默认情况下,异步方法挂起时会捕获当前上下文,捕获的上下文用于在恢复时调用异步方法的延续。


三、基于事件的异步模式(EAP)

System.Threading命名空间提供了创建高性能多线程应用程序所必需的所有工具,但要想有效地使用这些工具,需要有丰富的使用多线程软件工程的经验。对于相对简单的多线程应用程序,BackgroundWorker组件提供了一个简单的解决方案。对于更复杂的异步应用程序,考虑实现一个符合基于事件的异步模式的类。


基于事件的异步模式具有多线程应用程序的优点,同时隐藏了多线程设计中固有的许多复杂的问题。使用EAP模式的能够:


  • “在后台”执行耗时任务(例如下载和数据库操作),但不会中断你的应用程序。
  • 同时执行多个操作,每个操作完成时都会接到通知。
  • 等待资源变得可用,但不会停止(“阻止”)你的应用程序。
  • 使用熟悉的事件和委托模型与挂起的异步操作通信。

支持基于事件的异步模式的类将具有一个或多个命名为 MethodNameAsync 的方法。 这些方法可能会创建同步版本的镜像,这些同步版本会在当前线程上执行相同的操作。 该类还可能具有 MethodNameCompleted 事件,并且可能会具有 MethodNameAsyncCancel(或只是 CancelAsync)方法。


EAP常用的组件:

许多组件都支持异步执行工作,常用的有SoundPlayer和PictureBox组件,可以“在后台”加载音频和图像,同时主线程继续运行而不中断。

四、异步编程模型(APM)

使用IAsyncResult设计模式的异步操作时通过名微BeginOperatiobName和EndOperationName的两个方法来实现的,这两个方法分别开始和结束异常操作OperationName。例如:FileStream类提供BeginRead和EndRead方法来从文件异步读取字节。


在调用BeginOperationName后,应用程序可以继续在调用线程上执行指令,同时异步操作在另一个线程上执行。每次调用BeginOperationName时,应用程序还调用EndOperationName来获取操作的结果。


4.1 开始异步操作

BeginOperationName方法开始异步操作OperationName,并返回实现IAsyncResult接口的对象。IAsyncResult对象存储有关异步操作的信息。

1717419338926.png

BeginOperationName 方法采用该方法的同步版本的签名中声明的任何参数(由值传递或由引用传递)。 BeginOperationName 方法签名中不包含任何输出参数。 BeginOperationName 方法签名另外还包括两个其他参数。 第一个参数定义一个 AsyncCallback委托,此委托引用在异步操作完成时调用的方法。 如果调用方不希望在操作完成后调用方法,它可以指定 null (在 Visual Basic 中为Nothing )。 第二个参数是一个用户定义的对象。 此对象可用来向异步操作完成时调用的方法传递应用程序特定的状态信息。 如果 BeginOperationName 方法还采用其他一些操作特定的参数(例如,一个用于存储从文件读取的字节的字节数组),则 AsyncCallback和应用程序状态对象将是 BeginOperationName 方法签名中的最后两个参数。


BeginOperationName 立即返回对调用线程的控制。 如果 BeginOperationName 方法引发异常,则会在开始异步操作之前引发异常。 如果 BeginOperationName 方法引发异常,则意味着没有调用回调方法。


4.2 结束异步操作

EndOperationName方法用于结束异步操作OperationName。EndOperationName方法的返回值与其同步对应方法的返回值类型相同。并且是特定于异步操作的。


EndOperationName方法采用该方法同步版本的签名中声明的所有输出参数或引用参数。


如果调用EndOperationName时IAsyncResult对象表示的异步操作尚未完成,则EndOperationName将在异步操作完成之前阻止调用线程。异步操作引发的异常是从EndOperationName方法引发的。未定义多次使用同一IAsyncResult调用EndOperationName方法的效果。

相关实践学习
通过云拨测对指定服务器进行Ping/DNS监测
本实验将通过云拨测对指定服务器进行Ping/DNS监测,评估网站服务质量和用户体验。
目录
相关文章
|
14天前
|
开发框架 .NET 开发者
简化 ASP.NET Core 依赖注入(DI)注册-Scrutor
Scrutor 是一个简化 ASP.NET Core 应用程序中依赖注入(DI)注册过程的开源库,支持自动扫描和注册服务。通过简单的配置,开发者可以轻松地从指定程序集中筛选、注册服务,并设置其生命周期,同时支持服务装饰等高级功能。适用于大型项目,提高代码的可维护性和简洁性。仓库地址:&lt;https://github.com/khellang/Scrutor&gt;
36 5
|
2月前
|
存储 开发框架 JSON
ASP.NET Core OData 9 正式发布
【10月更文挑战第8天】Microsoft 在 2024 年 8 月 30 日宣布推出 ASP.NET Core OData 9,此版本与 .NET 8 的 OData 库保持一致,改进了数据编码以符合 OData 规范,并放弃了对旧版 .NET Framework 的支持,仅支持 .NET 8 及更高版本。新版本引入了更快的 JSON 编写器 `System.Text.UTF8JsonWriter`,优化了内存使用和序列化速度。
|
1月前
|
开发框架 .NET C#
在 ASP.NET Core 中创建 gRPC 客户端和服务器
本文介绍了如何使用 gRPC 框架搭建一个简单的“Hello World”示例。首先创建了一个名为 GrpcDemo 的解决方案,其中包含一个 gRPC 服务端项目 GrpcServer 和一个客户端项目 GrpcClient。服务端通过定义 `greeter.proto` 文件中的服务和消息类型,实现了一个简单的问候服务 `GreeterService`。客户端则通过 gRPC 客户端库连接到服务端并调用其 `SayHello` 方法,展示了 gRPC 在 C# 中的基本使用方法。
41 5
在 ASP.NET Core 中创建 gRPC 客户端和服务器
|
4月前
|
数据库 开发者
.NET 异步编程之谜:async/await 模式究竟隐藏着怎样的神奇力量?
【8月更文挑战第28天】在当今注重效率和响应性的软件开发领域,.NET 的 async/await 模式如同得力助手,简化异步代码编写,使代码更易理解和维护。通过后台执行耗时操作,如网络请求和数据库查询,避免阻塞主线程,显著提升系统响应性。此模式不仅适用于网络请求,还广泛应用于数据库操作和文件读写。合理使用 async/await 可大幅优化性能,但需注意避免过度使用、正确处理调用链及异常,以确保系统稳定性和高效性。深入探索 async/await,助您构建更出色的应用程序。
59 0
|
22天前
|
开发框架 缓存 .NET
GraphQL 与 ASP.NET Core 集成:从入门到精通
本文详细介绍了如何在ASP.NET Core中集成GraphQL,包括安装必要的NuGet包、创建GraphQL Schema、配置GraphQL服务等步骤。同时,文章还探讨了常见问题及其解决方法,如处理复杂查询、错误处理、性能优化和实现认证授权等,旨在帮助开发者构建灵活且高效的API。
24 3
|
1月前
|
开发框架 Java .NET
.net core 非阻塞的异步编程 及 线程调度过程
【11月更文挑战第12天】本文介绍了.NET Core中的非阻塞异步编程,包括其基本概念、实现方式及应用示例。通过`async`和`await`关键字,程序可在等待I/O操作时保持线程不被阻塞,提高性能。文章还详细说明了异步方法的基础示例、线程调度过程、延续任务机制、同步上下文的作用以及如何使用`Task.WhenAll`和`Task.WhenAny`处理多个异步任务的并发执行。
|
3月前
|
开发框架 监控 前端开发
在 ASP.NET Core Web API 中使用操作筛选器统一处理通用操作
【9月更文挑战第27天】操作筛选器是ASP.NET Core MVC和Web API中的一种过滤器,可在操作方法执行前后运行代码,适用于日志记录、性能监控和验证等场景。通过实现`IActionFilter`接口的`OnActionExecuting`和`OnActionExecuted`方法,可以统一处理日志、验证及异常。创建并注册自定义筛选器类,能提升代码的可维护性和复用性。
|
3月前
|
开发框架 .NET 中间件
ASP.NET Core Web 开发浅谈
本文介绍ASP.NET Core,一个轻量级、开源的跨平台框架,专为构建高性能Web应用设计。通过简单步骤,你将学会创建首个Web应用。文章还深入探讨了路由配置、依赖注入及安全性配置等常见问题,并提供了实用示例代码以助于理解与避免错误,帮助开发者更好地掌握ASP.NET Core的核心概念。
111 3
|
2月前
|
网络协议 大数据 网络架构
桥接模式和NET模式的区别
桥接模式和NET模式的区别
49 0
|
2月前
|
开发框架 JavaScript 前端开发
一个适用于 ASP.NET Core 的轻量级插件框架
一个适用于 ASP.NET Core 的轻量级插件框架