- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
根据 this link :
When you are awaiting on a method with await keyword, compiler generates bunch of code in behalf of you. One of the purposes of this action is to handle synchronization with the UI thread. The key
component of this feature is theSynchronizationContext.Current
which gets the synchronization context for the current thread.
SynchronizationContext.Current
is populated depending on the
environment you are in. TheGetAwaiter
method of Task looks up for
SynchronizationContext.Current
. If current synchronization context is not null, the continuation that gets passed to that awaiter will get posted back to that synchronization context.When consuming a method, which uses the new asynchronous language features, in a blocking fashion, you will end up with a deadlock if
you have an availableSynchronizationContext
. When you are consuming such methods in a blocking fashion (waiting on the Task with Wait method or taking the result directly from the Result property of the Task), you will block the main thread at the same time. When eventually the Task completes inside that method in the threadpool, it is going to invoke the continuation to post back to the main thread becauseSynchronizationContext.Current
is available and captured. But there is a problem here: the UI thread is blocked and you have a deadlock!
public class HomeController : Controller
{
public ViewResult CarsSync()
{
SampleAPIClient client = new SampleAPIClient();
var cars = client.GetCarsInAWrongWayAsync().Result;
return View("Index", model: cars);
}
}
public class SampleAPIClient
{
private const string ApiUri = "http://localhost:17257/api/cars";
public async Task<IEnumerable<Car>> GetCarsInAWrongWayAsync()
{
using (var client = new HttpClient())
{
var response = await client.GetAsync(ApiUri);
// Not the best way to handle it but will do the work for demo purposes
response.EnsureSuccessStatusCode();
return await response.Content.ReadAsAsync<IEnumerable<Car>>();
}
}
}
我无法理解上面语句的粗体 部分,但是当我测试上面的代码时,它按预期发生了死锁。但是我还是不明白为什么UI线程会被阻塞?
在这种情况下,可用的 SynchronizationContext
是什么?是 UI 线程吗?
最佳答案
我对此进行了完整解释 in my own blog post , 但在这里重申......
await
默认情况下将捕获当前“上下文”并恢复其 async
该上下文中的方法。此上下文是 SynchronizationContext.Current
除非它是 null
, 在这种情况下它是 TaskScheduler.Current
.
一次一个线程时可能会发生死锁 SynchronizationContext
并且您阻止代表异步代码的任务(例如,使用 Task.Wait
或 Task<T>.Result
)。请注意,导致死锁的是阻塞,而不仅仅是 SynchronizationContext
。 ;适当的解决方案(几乎总是)是使调用代码异步(例如,将 Task.Wait
/Task<T>.Result
替换为 await
)。在 ASP.NET 上尤其如此。
But I still can't understand why the UI thread is blocked?
您的示例在 ASP.NET 上运行;没有 UI 线程。
what is the available SynchronizationContext?
当前SynchronizationContext
应该是 AspNetSynchronizationContext
的实例,表示 ASP.NET 请求的上下文。此上下文一次只允许一个线程。
因此,通过您的示例:
当收到此操作的请求时,CarsSync
将在该请求上下文中开始执行。它继续到这一行:
var cars = client.GetCarsInAWrongWayAsync().Result;
本质上与此相同:
Task<IEnumerable<Car>> carsTask = client.GetCarsInAWrongWayAsync();
var cars = carsTask.Result;
因此,它继续调用 GetCarsInAWrongWayAsync
, 它会一直运行直到它到达第一个 await
(GetAsync
电话)。此时,GetCarsInAWrongWayAsync
捕获其当前上下文(ASP.NET 请求上下文)并返回不完整的 Task<IEnumerable<Car>>
.当 GetAsync
下载完成,GetCarsInAWrongWayAsync
将继续在该 ASP.NET 请求上下文中执行并(最终)完成它已经返回的任务。
但是,一旦GetCarsInAWrongWayAsync
返回未完成的任务,CarsSync
阻塞当前线程,等待该任务完成。请注意,当前线程位于该 ASP.NET 请求上下文中,因此 CarsSync
会阻止 GetCarsInAWrongWayAsync
永远不会恢复执行,导致死锁。
最后一点,GetCarsInAWrongWayAsync
是一个好的方法。如果用ConfigureAwait(false)
就更好了,但这实际上不是错误的。 CarsSync
是导致死锁的方法;它调用Task<T>.Result
是错的。适当的修复是更改 CarsSync
:
public class HomeController : Controller
{
public async Task<ViewResult> CarsSync()
{
SampleAPIClient client = new SampleAPIClient();
var cars = await client.GetCarsInAWrongWayAsync();
return View("Index", model: cars);
}
}
关于c# - 使用 SynchronizationContext 时异步/等待死锁,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34151179/
我试图让脚本暂停大约 1 秒,然后继续执行脚本,但我似乎无法弄清楚如何做。这是我的代码: function hello() { alert("Hi!") //I need about a 1
wait() 和 wait(timeout) 之间有什么区别。无论如何 wait() 需要等待通知调用,但为什么我们有 wait(timeout)? 那么 sleep(timeout) 和 wait(
我需要做什么: 我有一个带有文件输入和隐藏文本输入的上传表单。用户上传图像,图像被操作,然后发送到远程服务器进行处理,这需要几秒钟,然后远程服务器将最终的图像发送回家庭服务器,并保存在新文件夹中。 J
大家好,我正在使用 Visual C++ 2010,尝试使用 Winsock 编写服务器/客户端应用程序...我不确定为什么,但有时服务器会在 listen() 函数处等待,有时会在 accept 处
任务描述 我为我的 Angular 应用程序实现了 CRSF 保护。服务器检查 crsf token 是否位于请求的 header “X-CSRF-TOKEN”中。如果不是,它会发送一个 HTTP 响
我想做这个例子https://stackoverflow.com/a/33585993/1973680同步。 这是正确的实现方式吗? let times= async (n,f)=>{
我如何将 while 循环延迟到 1 秒间隔,而不会将其运行的整个代码/计算机的速度减慢到一秒延迟(只是一个小循环)。 最佳答案 Thread.sleep(1000); // do nothing f
我知道这是一个重复的问题。但是我无法通过解释来理解。我想用一个很好的例子来清楚地理解它。任何人都可以帮忙吗。 “为什么我们从同步上下文中调用 wait()、notify() 方法”。 最佳答案 当我们
我有一个 click 事件,该事件是第一次从另一个地方自动触发的。我的问题是它运行得太快,因为所需的变量仍在由 Flash 和 Web 服务定义。所以现在我有: (function ($) {
我有如下功能 function async populateInventories(custID){ this.inventories = await this.inventoryServic
我一直对“然后”不被等待的行为感到困扰,我明白其原因。然而,我仍然需要绕过它。这是我的用例。 doWork(family) { return doWork1(family)
我想我理解异步背后的想法,返回一个Future,但是我不清楚异步在一个非常基本的层面上如何表现。据我了解,它不会自动在程序中创建异步行为。例如: import 'dart:async'; main()
我正在制作一个使用异步的Flutter应用程序,但它的工作方式不像我对它的了解。所以我对异步和在 Dart 中等待有一些疑问。这是一个例子: Future someFunction() async {
我在 main.tf 中创建资源组和 vNet,并在同一文件中引用模块。问题是,模块无法从模块访问这些资源。相关代码(删除了大部分代码,只留下相关部分): main.tf: module "worke
我的代码的问题是,当代码第一次运行时,我试图获取的 dom 元素并不总是存在,如果它不存在,那么永远不会做出 promise 。 我是否可以等到 promise 做出后再尝试实现它? 我希望我的最后一
所以,过去几天我一直在研究这段代码,并尝试实现回调/等待/任何需要的东西,但没有成功。 问题是,我如何等待响应,直到我得到两个函数的回调? (以及我将如何实现) 简而言之,我想做的是: POST 发生
谁能帮我理解这一点吗? 如果我们有一个类: public class Sample{ public synchronized method1(){ //Line1 .... wait();
这是我编写的代码,用于测试 wait() 和 notify() 的工作。现在我有很多疑问。 class A extends Thread { public void run() { try
我有以下代码由于语法错误而无法运行(在异步函数外等待) 如何使用 await 定义变量并将其导出? 当我这样定义一个变量并从其他文件导入它时,该变量是只创建一次(第一次读取文件时?)还是每次导入时都创
一个简单的线程程序,其中写入器将内容放入堆栈,读取器从堆栈中弹出。 java.util.Stack; import java.util.concurrent.ExecutorService; impo
我是一名优秀的程序员,十分优秀!