C# :异步编程的注意点

在上一篇《C#:异步编程中的 async 和 await》 中简单介绍了在 C# 中的异步编程以及 async 和 await 编程模型,本文介绍下异步编程的注意事项,主要有以下几个方面。

同步中调用异步

在同步代码中调用异步代码,容易导致死锁,所以在实际使用异步编程时,推荐的做法是一直异步到底。先来看一个会出现死锁的代码:

class Program
{static void Main(string[] args){while (true){Task.Run(MethodSync);Thread.Sleep(100);}}static void MethodSync(){//string result =MethodAsync().Result;MethodAsync().Wait();}static async Task<string> MethodAsync(){await Task.Run(() =>{Thread.Sleep(2000);});Console.WriteLine("MethodAsync End");return "success";}
}
  • Main  方法中使用 Task.Run 进行新的任务的创建,每个间隔 100  毫秒,模拟多次请求;

  • 在同步方法 MethodSync 中调用异步方法 MethodAsync;

  • 同步方法中使用 .Result  或者调用 Wait() 方法进行等待;

运行上面代码,控制台会输出几次 MethodAsync End 后就会停止,这时死锁已经发生。可以观察到控制台程序使用的线程数会不断增加:

发生死锁的原因是:
  • 程序运行时,有一个线程 A 开始执行同步方法 MethodSync ,执行到同步方法中的 .Result 或 Wait() 时,会产生一个线程 B 进行异步方法的调用;

  • 线程 A 会等着 线程 B 完成,然后线程 A 才继续执行后面的代码;

  • 当并发比较大的时候,线程池的线程不够用,需要创建新的线程,创建线程的速度赶不上 Task 创建的速度的时候,就会造成堵塞,最终死锁。

只需要将 MethodSync 同步方法修改为异步就可以解决此问题:

static async Task MethodASync1()
{await MethodAsync();
}
  • 程序运行时,有一个线程 A 开始执行异步方法 MethodASync1 ,执行到 await 时,会产生一个线程 B 进行异步方法 MethodAsync 的调用;

  • 线程 A 不会等着 线程 B 完成,而是会被线程池收回做其他的事情;

  • 当线程 B 完成后,线程池会重新分配新的线程来进行后续的处理,所以整个过程不会有堵塞。

当然,有些时候我们需要在同步方法中调用异步方法,有下面两个方法:

  • 借助这个组件来进行处理:https://github.com/StephenCleary/AsyncEx ;

  • 使用 ConfigureAwait(false) 。

合理使用 void 返回值

  • 使用 void 无法确定方法在什么时候调用完成,因为没有任何内容返回,不像 Task 的返回值,可以获取到相关的状态;

  • 返回 void 的异步方法没有办法在调用的时候使用 await ;

  • 对 void 方法进行调用时无法捕获异常。

因为上面的原因,所以我们在写代码时尽量不要在异步方法上返回 void ,但有两种情况也还是可以使用 void 返回值:

1、事件,比如在 Winform 程序中的按钮事件

private void btnTest_Click(object sender, EventArgs e)        
{            await WriteLog();        
}

如果要将 btnTest_Click 的返回值修改为 async Task ,编译时会报错。

2、记录日志之类的方法,或者说该方法执行的操作和主任务关系不大,无需知道处理的结果时。

异常处理

当我们编写同步代码时,常用 try catch 来进行异常捕获,例如下面代码:

class Program
{static void Main(string[] args){try{TestException();}catch (Exception ex){//TestException 方法抛出的异常会在这里被捕获Console.WriteLine(ex.Message);}}static void TestException(){throw new Exception("Test Exception");}
}

同样的方式对异步方法进行 try catch ,会发现 catch 中的代码并没有执行:

class Program
{static void Main(string[] args){try{TestExceptionAsync();}catch (Exception ex){//此处不会被调用Console.WriteLine(ex.Message);}Console.WriteLine("main end");Console.ReadLine();}static async Task TestExceptionAsync(){await Task.Delay(200);throw new Exception("Test TestExceptionAsync");}
}

要对异常方法进行异常捕获,必须使用 await 修饰符 、调用 Wait() 方法或者访问 Result 属性:

static async Task Main(string[] args)
{try{//var result = TestExceptionAsync().Result;//TestExceptionAsync().Wait();await TestExceptionAsync();}catch (Exception ex){Console.WriteLine(ex.Message);}Console.WriteLine("main end");Console.ReadLine();
}

在异步方法的返回类型 Task 类中,有一个 Exception 属性,该属性返回的类型为 AggregateException ,而在 AggregateException 的内部又有一个 InnerExceptions 属性用来包装所有异常的集合。

对于使用 await 修饰符和调用 Wait() 方法、访问 Result 属性对于异常的捕获是有区别的:

Wait() 、Result

当使用Wait 或 Result 的时候,异步方法是将自身的 AggregateException 对象往上抛,这样在异常处理的时候就会比较麻烦,我们需要这样来进行异常的解析:

static async Task Main(string[] args)
{try{TestExceptionAsync().Wait();}catch (AggregateException aggregateException){foreach (var ex in aggregateException.InnerExceptions){Console.WriteLine(ex.Message);}}Console.WriteLine("main end");Console.ReadLine();
}

如果直接获取 aggregateException 的 Message 属性,则会输出:

One or more errors occurred. (Test TestExceptionAsync)

await

使用 await 修饰符,发生异常的时候,抛出的不是 AggregateException 对象,而是 AggregateException 对象中的 InnerExceptions 属性中找出第一个返回,随意在使用 await 修饰符的场景下,捕获异常的写法是符合我们编程习惯的。

static async Task Main(string[] args)
{try{await TestExceptionAsync();}catch (Exception ex){Console.WriteLine(ex.Message);}Console.ReadLine();
}

希望本文对您有所帮助!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/306596.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

makefile 打印变量_[Makefile] 缩进与空格--记录踩过的坑

今天折腾了好久&#xff0c;就为了debug两个makefile的bug。虽然最后找到原因了&#xff0c;但是&#xff0c;怎么说呢&#xff0c;用现在流行的话来说&#xff0c;实在是意难平啊&#xff01;必须写一篇记录一下&#xff01;第一个问题&#xff0c;是个语法高亮问题。今天观察…

算法设计与分析——贪心算法——背包问题

0-1背包问题&#xff1a; 前提&#xff1a;给定n种物品和一个背包。物品i的重量是Wi&#xff0c;其价值为Vi&#xff0c;背包的容量为C。 问题&#xff1a;应如何选择装入背包的物品&#xff0c;使得装入背包中物品的总价值最大? 背包问题&#xff1a; 与0-1背包问题类似&…

企业级精致 Blazor 套件 BootstrapBlazor 介绍

BootstrapBlazor1、前言 Blazor 作为一种 Web 开发的新技术已经发展有一段时间了&#xff0c;有些人标称 无 JS 无 TS&#xff0c;我觉得有点误导新人的意味&#xff0c;也有人文章大肆宣传 Blazor 是 JavaScript 的终结者&#xff0c;是为了替代 JavaScript 而生的&#xff0c…

算法设计与分析——贪心算法——最优装载问题

有一批集装箱要装上一艘载重量为c的轮船。其中集装箱i的重量为Wi。最优装载问题要求确定在装载体积不受限制的情况下&#xff0c;将尽可能多的集装箱装上轮船。 #include<iostream> #include<algorithm> #include<cstring> using namespace std;typedef str…

AgileConfig-轻量级配置中心 1.1.0 发布,支持应用间配置继承

AgileConfig轻量级配置中心自第一个版本发布不知不觉已经半年了。在并未进行什么推广的情况下收到了250个star&#xff0c;对我有很大的鼓舞&#xff0c;并且也有不少同学试用&#xff0c;并且给出了宝贵的意见&#xff0c;非常感谢他们。其中有一些意见非常好&#xff0c;但是…

如何在 C# 中使用 Dapper ORM

译文链接&#xff1a;https://www.infoworld.com/article/3025784/how-to-use-the-dapper-orm-in-c.html?nsdrtrue对象关系映射&#xff08;ORM&#xff09;这个概念已经存在很长时间了&#xff0c;ORM的作用就是用来解决 编程领域的 object model 和关系数据库中的 data mode…

GraphQL:简单开开始一个查询

GraphQL 既是一种用于 API 的查询语言也是一个满足你数据查询的运行时。GraphQL 对你的 API 中的数据提供了一套易于理解的完整描述&#xff0c;使得客户端能够准确地获得它需要的数据&#xff0c;而且没有任何冗余&#xff0c;也让 API 更容易地随着时间推移而演进&#xff0c…

算法设计与分析——回溯法——批处理作业调度

问题描述&#xff1a;给定n个作业的集合{J1,J2,…,Jn}。每个作业必须先由机器1处理&#xff0c;然后由机器2处理。作业Ji需要机器j的处理时间为tji。对于一个确定的作业调度&#xff0c;设Fji是作业i在机器j上完成处理的时间。所有作业在机器2上完成处理的时间和称为该作业调度…

探索.NET平台中的SIMD内在函数Vector

概述Vector&#xff08;向量&#xff09;是一种序列式容器&#xff0c;事实上和数组差不多&#xff0c;但它比数组更优越。一般来说数组不能动态拓展&#xff0c;因此在程序运行的时候不是浪费内存&#xff0c;就是造成越界。而Vector刚好弥补了这个缺陷&#xff0c;它的特征是…

算法设计与分析——回溯法——装载问题

0027算法笔记——【回溯法】回溯法与装载问题 自己写的代码&#xff1a; #include <iostream> using namespace std; template <class Type> class Loading {//friend Type MaxLoading(Type[],Type,int,int []);//private:public:void Backtrack(int i);int n, …

深入解析 C# 的 String.Create 方法

作者&#xff1a;Casey McQuillan译者&#xff1a;精致码农原文&#xff1a;http://dwz.win/YVW说明&#xff1a;原文比较长&#xff0c;翻译时精简了很多内容&#xff0c;对于不重要的细枝末节只用了一句话概括&#xff0c;但不并影响阅读。你还记得上一次一个无足轻重的细节点…

算法设计与分析——回溯法——n皇后问题

一、什么是N皇后问题&#xff1f; 在nn格的棋盘上放置彼此不受攻击的n个皇后。按照国际象棋的规则&#xff0c;皇后可以攻击与之处在同一行或同一列或同一斜线上的棋子。n后问题等价于再nn的棋盘上放置n个皇后&#xff0c;任何2个皇后不妨在同一行或同一列或同一斜线上。 问题…

全局程序集缓存gac中安装程序集_我就不信2W字把源码拆的这么碎,你还不明白mybatis缓存...

前言不知道大家看到这张图感觉怎么样&#xff0c;不是难&#xff0c;一共也没有几个组件&#xff0c;但是真的让我想当头疼&#xff0c;因为在面试的时候&#xff0c;就这张图&#xff0c;对&#xff0c;你没看错&#xff0c;就这几个组件&#xff0c;那是让我相当难受啊MyBati…

GraphQL:和EntityFramework更配哦

GraphQL 既是一种用于 API 的查询语言也是一个满足你数据查询的运行时。GraphQL 对你的 API 中的数据提供了一套易于理解的完整描述&#xff0c;使得客户端能够准确地获得它需要的数据&#xff0c;而且没有任何冗余&#xff0c;也让 API 更容易地随着时间推移而演进&#xff0c…

算法设计与分析——回溯法——符号三角形问题

#include<iostream> using namespace std;class Triangle{public:void Backtrack(int t);int n;//第一行的符号个数 int half;//n*(n1)/4 int count;//当前—的个数 int **p;//符号三角形矩阵 long sum; //已找到的符号三角形数 };void Triangle::Backtrack(int t) {if(…

mysql 默认事务隔离级别_MySQL 事务隔离级别详解

个人公众号『码农札记』&#xff0c;欢迎关注&#xff0c;查看更多精彩文章。 简介&#xff1a; MySQL的事务隔离级别一共有四个&#xff0c;分别是读未提交、读已提交、可重复读以及可串行化。四个特性ACID原子性 &#xff08;Atomicity&#xff09;事务开始后所有操作&#x…

如何在 Asp.Net Core 中对请求进行限流

译文链接&#xff1a;https://www.infoworld.com/article/3442946/how-to-implement-rate-limiting-in-aspnet-core.html在应用程序开发时&#xff0c;或许你有这样的想法&#xff0c;控制用户的请求频率来防止一些用户的恶意攻击&#xff0c;具体的说就是&#xff1a;为了预防…

算法设计与分析——动态规划——石子合并问题

1.石子合并问题 在一个圆形操场的四周摆放着n堆石子。现要将石子有序地合并成一堆。规定每次只能选相邻的2堆石子合并成新的一堆&#xff0c;并将新的一堆石子数记为该次合并的得分。设计一个算法&#xff0c;计算出将n堆石子合并成一堆的最小得分和最大得分。 #include<st…

软件层面可以做到重启本地串口吗_手机关机还是重启好?get这几招,手机更流畅...

遇到手机卡顿&#xff0c;很多人都会不自觉的选择重启手机&#xff0c;还是不行&#xff0c;就关机等一会儿再开机&#xff0c;这样几次下来手机真的就顺畅多了。那么关机和重启到底有什么区别&#xff1f;还有哪些方法可以保持手机流畅&#xff1f;跟着小编来了解一下&#xf…

在传统行业做数字化转型之团队篇

【数字化转型】| 作者 / Edison Zhou这是EdisonTalk的第309篇原创内容在过去的两年时间里&#xff0c;我加入了一家传统行业的企业参与其数字化转型的过程&#xff0c;现在我将我的经历分享出来&#xff0c;本文是第四部分—团队篇&#xff0c;主要会介绍一下我所在的经济适用型…