[译]async/await中使用阻塞式代码导致死锁

原文:[译]async/await中使用阻塞式代码导致死锁

这篇博文主要是讲解在async/await中使用阻塞式代码导致死锁的问题,以及如何避免出现这种死锁。内容主要是从作者Stephen Cleary的两篇博文中翻译过来.

原文1:Don‘tBlock on Async Code

原文2:why the AspNetSynchronizationContext was removed

示例代码:async_await中使用阻塞式代码导致死锁.rar

一、async/await 异步代码运行流程

async/await是在.NET4.5版本引入的关键字,让开发者可以更加轻松的创建异步方法。

我们从下图来认识async/await的运行流程:

二、在异步代码中阻塞,导致死锁的示例

UI 示例

单击一个按钮,将发起一个REST远程请求并且将结果显示到textbox控件上。(这是一个Windows Forms程序,同样也适用于其他任何UI应用程序)

// My "library" method.

publicstaticasync Task<JObject> GetJsonAsync(Uri uri)

{

using (var client = new HttpClient())

{

var jsonString = await client.GetStringAsync(uri);

return JObject.Parse(jsonString);

}

}

// My "top-level" method.

publicvoid Button1_Click(...)

{

var jsonTask = GetJsonAsync(...);

textBox1.Text = jsonTask.Result;

}

类库方法GetJsonAsync发起REST远程请求并且将结果解析为JSON返回。Button1_Click方法调用Task .Result阻塞等待GetJsonAsync处理完毕并显示结果

这段代码会死锁。

ASP.NET 示例

在类库方法GetJsonAsync中发起一个REST远程请求,这次这个GetJsonAsync在ASP.NET context中被调用。(示例是Web API项目,同样适用于任何一个ASP.NET应用程序 - 注:非ASP.NET Core应用)

// My "library" method.

publicstaticasync Task<JObject> GetJsonAsync(Uri uri)

{

using (var client = new HttpClient())

{

var jsonString = await client.GetStringAsync(uri);

return JObject.Parse(jsonString);

}

}

// My "top-level" method.

publicclassMyController : ApiController

{

publicstring Get()

{

var jsonTask = GetJsonAsync(...);

return jsonTask.Result.ToString();

}

}

这段代码也会死锁。与UI示例是同一个原因。

三、是什么原因导致的死锁呢?

await一个Task后,在恢复继续执行时,会试图进入await之前的context。

第一个示例中,这个context是UI context(任何UI应用,除了控制台应用)。在第二个示例中,这个context是ASP.NET request context。

另一个需要注意的点:ASP.NET request context 没有绑定到特定的线程上(像UI context一样),但是request context同一时刻只允许被绑定到一个线程上。我曾经在MSDN上有发表过《关于SynchronzationContext》的文章.

死锁是怎么发生的呢?我们从top-level方法开始(UI的Button1_Click方法或ASP.NET的MyContoller.Get方法)

1.         top-level方法调用GetJsonAsync(在UI/ASP.NET context中)。

2.         GetJsonAsync通过HttpClient.GetStringAsync发起REST远程请求(在UI/ASP.NET context中)。

3.         GetStringAsync返回一个未完成Task,标识REST远程请求还未处理完

4.         GetJsonAsync方法中await GetStringAsync返回的未完成Task。等Task执行完毕,

会重新捕获等待之前的context并使用它继续执行GetJsonAsync。

5.         GetJsonAsync中await后,携带context的线程会跳出GetJsonAsync方法,继续执行后面的代码。并在jsonTask.Result发生阻塞。此时携带context的线程被阻塞了。

6.         最终,REST请求处理完,GetStringAsync返回的Task处理完成。

7.         GetJsonAsync方法准备继续运行,并且等待context可用,以便在context中执行。

8.         发生context死锁。在top-level方法中已经阻塞了携带context的线程,等待GetJsonAsync返回的Task完成。而此时,GetJsonAsync方法正在等待context被释放,以便在context中继续执行。

四、防止死锁

这里有三个最佳实践来避免这种死锁(更详细的传送门)。

1.         在你的”library”异步方法中,返回未完成Task时都调用ConfigureAwait(false)。

2.         始终使用 Async,不要混合阻塞式代码和异步代码。

3.         ASP.NET 升级为ASP.NET Core。在ASP.NET Core框架中,已经移除SynchronizationContext

按照第一条最佳实践,”library”中的异步方法修改如下:

publicstaticasync Task<JObject> GetJsonAsync(Uri uri)

{

using (var client = new HttpClient())

{

var jsonString = await client.GetStringAsync(uri).ConfigureAwait(false);

return JObject.Parse(jsonString);

}

}

ConfigureAwait(continueOnCapturedContext: false):continueOnCapturedContext参数表示是否尝试将延续任务封送回原始上下文。

ConfigureAwait(false)改变了GetJsonAsync的延续行为,使它不用在原来的context中恢复。GetJsonAsync将直接在线程池线程中恢复,这使得GetJsonAsync能完成任务,并且无需重新进入原来的context

按照第二条最佳实践。修改”top-level”方法如下:

publicasyncvoid Button1_Click(...)

{

var json = await GetJsonAsync(...);

textBox1.Text = json;

}

publicclassMyController : ApiController

{

publicasync Task<string> Get()

{

var json = await GetJsonAsync(...);

return json.ToString();

}

}

这样修改,改变了top-level方法的阻塞行为。所有的”等待”都是”异步等待”,这样context就不会被阻塞。

其他”异步等待”指导原则:


执行以下操作…


不要使用以下方式…


使用以下方式


创建Task


Task constructor


Task.Run or TaskFactory.StartNew


检索后台任务的结果


Task.Wait 或 Task.Result


await


等待任何任务完成


Task.WaitAny


await Task.WhenAny


检索多个任务的结果


Task.WaitAll


await Task.WhenAll


等待一段时间


Thread.Sleep


await Task.Delay

五、在ASP.NET Core框架中,已经移除SynchronizationContext

为什么AspNetSynchronizationContext在ASP.NET Core中被移除。尽管我不知道ASP.NET团队内部是什么观点,但我认为的观点是两个:性能和简单。

性能方面:

在没有SynchronizationContext的ASP.NET Core中,当一个async/await异步处理恢复执行时,会从线程池中获取一个线程并且执行继续操作。

1.         避免了把操作排队到request context队列(request context同一时刻只允许被绑定到一个线程上)

2.         避免了因为携带 request context 的线程被阻塞而发生“死锁”

3.         不需要重新进入request context(重新进入request context涉及到很多内部作业任务,例如:设置HttpContext.Current和当前线程的身份标识(identity)和语言(culture))

简单化:

旧版本ASP.NET中SynchronizationContext工作的很好,但是也存在棘手的问题,特别是在身份管理方面(参考:Thread.CurrentPrincipal VS HttpContext.Current.User)

六、async/await避免阻塞式死锁最佳实践

1.         在你的“library”异步方法中,返回未完成Task时都调用ConfigureAwait(false),标识不需要将延续任务封送回原始上下文。

尽管在ASP.NET Core中,不用再调用ConfigureAwait(false)来防止死锁。但由于你提供的“类库”可能被用于UI 应用(eg:winform、wpf等)、旧版本ASP.NET应用、其他还存在context的应用。

2.         更好的解决方案是“始终使用 async,不要混合阻塞式代码和异步代码”。

因为当你在异步代码中阻塞程序,将失去异步代码带来的所有好处。并且异步代码释放当前线程带来的伸缩性也会失效。

3.         将ASP.NET项目升级为ASP.NET Core项目

推荐阅读:

Async/Await FAQ(原文##译文

Stephen Cleary 的开源组件:AsyncEx

Async/Await 异步编程中的最佳做法(原文##译文

(xishuai)ASP.NET混合阻塞式代码和异步代码,线程切换变化

原文地址:https://www.cnblogs.com/lonelyxmas/p/10242416.html

时间: 2024-10-12 23:19:16

[译]async/await中使用阻塞式代码导致死锁的相关文章

[.NET] 使用 async &amp; await 一步步将同步代码转换为异步编程

使用 async & await 一步步将同步代码转换为异步编程 [博主]反骨仔 [出处]http://www.cnblogs.com/liqingwen/p/6079707.html  序 上次,博主通过<利用 async & await 的异步编程>一文介绍了 async & await 的基本用法及异步的控制流和一些其它的东西. 今天,博主打算从创建一个普通的 WPF 应用程序开始,看看如何将它逐步转换成一个异步的解决方案.你知道吗?使用 Visual Studi

async/await 中await接收的promise的问题

在async/await中,await接收的需要是一个promise对象,那么我这样写: async getAddressList () { this.list = await AreaSvr.getList(320100); } getAddressList().catch((err) => { ... }); AddressSvr.getList = function (pid) { return new Promise((resolve, reject) => { Vue._http.g

asp.net 异步(async/await)中访问HttpContext的问题

以web api上传文件的官方例子为例: await Request.Content.ReadAsMultipartAsync(provider); 项目里面多处用到session,包括在其他类库中通过HttpContext获取Session对象,在await之后,直接访问Session均为空了. 怎么办,文件得上传啊. 网络搜索无果,后来发现HttpContext竟然支持Set方法,那么在await之前存储HttpContext的引用,在await之后将引用再赋给HttpContext,这样似

async/await中reject的问题

promise 返回的 resolve 对象可能用 await 去接,但是 reject 无法用 await 接收到,所以要用 try catch 去处理 例如发送邮件的接口设置: async function verify(body){ //发送邮件服务器的配置 let transporter = nodeMailer.createTransport({ service:'qq', auth:{ user:SMTP_CONF.user, pass:SMTP_CONF.pass } }) //用

异步async await 相关知识点总结以及代码练习

<script> const setTimeoutToPromise = duration => new Promise(resolve => { setTimeout(resolve, duration) }) export default { data() { return { mysrc: true } }, methods: { s1(a){ console.log(a) }, s2(a){ console.log(a) }, s3(a){ console.log(a) }

Maven的Pom文件中的隐式依赖导致Jar包冲突的问题

在一次的maven项目中遇到这样一个bug: 编译器没有报什么错,但无法编译,或者能编译,项目启动不了.后来我才发现是以下的问题: 项目中的pom文件中,依赖了webx3.core,而webx3.core又隐式依赖了fasttext相关的jar包,同时我在pom中也引人了fasttext.all, fasttext.all也隐式依赖了fasttext相关的jar包,两类jar包版本还不一样,这样就导致了jar包冲突的问题,牵扯到的pom文件依赖如下: <dependency><group

Async/Await 异步编程中的最佳做法

近日来,涌现了许多关于 Microsoft .NET Framework 4.5 中新增了对 async 和 await 支持的信息. 本文旨在作为学习异步编程的“第二步”:我假设您已阅读过有关这一方面的至少一篇介绍性文章. 本文不提供任何新内容,Stack Overflow.MSDN 论坛和 async/await FAQ 这类在线资源提供了同样的建议. 本文只重点介绍一些淹没在文档海洋中的最佳做法. 本文中的最佳做法更大程度上是“指导原则”,而不是实际规则. 其中每个指导原则都有一些例外情况

异步编程中的最佳做法(Async/Await) --转

近日来,涌现了许多关于 Microsoft .NET Framework 4.5 中新增了对 async 和 await 支持的信息. 本文旨在作为学习异步编程的“第二步”:我假设您已阅读过有关这一方面的至少一篇介绍性文章. 本文不提供任何新内容,Stack Overflow.MSDN 论坛和 async/await FAQ 这类在线资源提供了同样的建议. 本文只重点介绍一些淹没在文档海洋中的最佳做法. 本文中的最佳做法更大程度上是“指导原则”,而不是实际规则. 其中每个指导原则都有一些例外情况

.NET 中的 async/await 异步编程

前言 最近在学习Web Api框架的时候接触到了async/await,这个特性是.NET 4.5引入的,由于之前对于异步编程不是很了解,所以花费了一些时间学习一下相关的知识,并整理成这篇博客,如果在阅读的过程中发现不对的地方,欢迎大家指正. 同步编程与异步编程 通常情况下,我们写的C#代码就是同步的,运行在同一个线程中,从程序的第一行代码到最后一句代码顺序执行.而异步编程的核心是使用多线程,通过让不同的线程执行不同的任务,实现不同代码的并行运行. 前台线程与后台线程 关于多线程,早在.NET2