- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
编辑: This question看起来它可能是同样的问题,但没有回应......
编辑:在测试用例 5 中,任务似乎卡在 WaitingForActivation
中状态。
我在 .NET 4.5 中使用 System.Net.Http.HttpClient 遇到了一些奇怪的行为 - 其中“等待”调用(例如)的结果 httpClient.GetAsync(...)
永远不会回来。
这仅在使用新的 async/await 语言功能和 Tasks API 时发生在某些情况下 - 代码似乎总是在仅使用延续时工作。
这是一些重现问题的代码 - 将其放入 Visual Studio 11 中的新“MVC 4 WebApi 项目”中以公开以下 GET 端点:
/api/test1
/api/test2
/api/test3
/api/test4
/api/test5 <--- never completes
/api/test6
/api/test5
之外,这里的每个端点都返回相同的数据(来自 stackoverflow.com 的响应 header )。永远不会完成。
public class BaseApiController : ApiController
{
/// <summary>
/// Retrieves data using continuations
/// </summary>
protected Task<string> Continuations_GetSomeDataAsync()
{
var httpClient = new HttpClient();
var t = httpClient.GetAsync("http://stackoverflow.com", HttpCompletionOption.ResponseHeadersRead);
return t.ContinueWith(t1 => t1.Result.Content.Headers.ToString());
}
/// <summary>
/// Retrieves data using async/await
/// </summary>
protected async Task<string> AsyncAwait_GetSomeDataAsync()
{
var httpClient = new HttpClient();
var result = await httpClient.GetAsync("http://stackoverflow.com", HttpCompletionOption.ResponseHeadersRead);
return result.Content.Headers.ToString();
}
}
public class Test1Controller : BaseApiController
{
/// <summary>
/// Handles task using Async/Await
/// </summary>
public async Task<string> Get()
{
var data = await Continuations_GetSomeDataAsync();
return data;
}
}
public class Test2Controller : BaseApiController
{
/// <summary>
/// Handles task by blocking the thread until the task completes
/// </summary>
public string Get()
{
var task = Continuations_GetSomeDataAsync();
var data = task.GetAwaiter().GetResult();
return data;
}
}
public class Test3Controller : BaseApiController
{
/// <summary>
/// Passes the task back to the controller host
/// </summary>
public Task<string> Get()
{
return Continuations_GetSomeDataAsync();
}
}
public class Test4Controller : BaseApiController
{
/// <summary>
/// Handles task using Async/Await
/// </summary>
public async Task<string> Get()
{
var data = await AsyncAwait_GetSomeDataAsync();
return data;
}
}
public class Test5Controller : BaseApiController
{
/// <summary>
/// Handles task by blocking the thread until the task completes
/// </summary>
public string Get()
{
var task = AsyncAwait_GetSomeDataAsync();
var data = task.GetAwaiter().GetResult();
return data;
}
}
public class Test6Controller : BaseApiController
{
/// <summary>
/// Passes the task back to the controller host
/// </summary>
public Task<string> Get()
{
return AsyncAwait_GetSomeDataAsync();
}
}
最佳答案
您正在滥用 API。
情况是这样的:在 ASP.NET 中,一次只有一个线程可以处理一个请求。如有必要,您可以进行一些并行处理(从线程池中借用附加线程),但只有一个线程具有请求上下文(附加线程没有请求上下文)。
这是 managed by the ASP.NET SynchronizationContext
.
默认情况下,当您 await
Task
,该方法在捕获的 SynchronizationContext
上恢复(或捕获的 TaskScheduler
,如果没有 SynchronizationContext
)。通常,这正是您想要的:异步 Controller 操作将 await
一些东西,当它恢复时,它会以请求上下文恢复。
所以,这就是为什么 test5
失败:
Test5Controller.Get
执行 AsyncAwait_GetSomeDataAsync
(在 ASP.NET 请求上下文中)。 AsyncAwait_GetSomeDataAsync
执行 HttpClient.GetAsync
(在 ASP.NET 请求上下文中)。 HttpClient.GetAsync
返回未完成的 Task
. AsyncAwait_GetSomeDataAsync
等待 Task
;由于不完整,AsyncAwait_GetSomeDataAsync
返回未完成的 Task
. Test5Controller.Get
块 当前线程直到 Task
完成。 Task
返回者 HttpClient.GetAsync
完成了。 AsyncAwait_GetSomeDataAsync
尝试在 ASP.NET 请求上下文中恢复。但是,该上下文中已经有一个线程:线程阻塞在 Test5Controller.Get
中。 . test1
、 test2
和 test3
): Continuations_GetSomeDataAsync
在 ASP.NET 请求上下文之外调度线程池的延续。这允许 Task
返回者 Continuations_GetSomeDataAsync
无需重新输入请求上下文即可完成。 test4
和 test6
):由于 Task
等待,ASP.NET 请求线程不会被阻塞。这允许 AsyncAwait_GetSomeDataAsync
在准备好继续时使用 ASP.NET 请求上下文。 async
方法,使用 ConfigureAwait(false)
只要有可能。在你的情况下,这会改变 AsyncAwait_GetSomeDataAsync
成为 var result = await httpClient.GetAsync("http://stackoverflow.com", HttpCompletionOption.ResponseHeadersRead).ConfigureAwait(false);
Task
s;它是 async
一直往下。换句话说,使用 await
而不是 GetResult
( Task.Result
和 Task.Wait
也应该替换为 await
)。 AsyncAwait_GetSomeDataAsync
方法的其余部分)在一个基本线程池线程上运行,该线程池线程不必进入 ASP.NET 请求上下文; Controller 本身是
async
(它不会阻塞请求线程)。
async
/ await
intro post ,其中包括如何 Task
的简要说明等待者使用 SynchronizationContext
. SynchronizationContext
将请求上下文一次限制为一个线程。 关于c# - HttpClient.GetAsync(...) 在使用 await/async 时永远不会返回,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10343632/
我有带皮肤的 DNN。我的 head 标签有 runat="server"所以我尝试在 head 标签内添加一个标签 "> 在后面的代码中,我在属性中设置了 var GoogleAPIkey。问题是它
我在 Node.JS 中有一个导出模块 exports.doSomethingImportant= function(req, res) { var id = req.params.id; Demo.
我是 F# 的新手,我一直在阅读 F# for Fun and Profit。在为什么使用 F#? 系列中,有一个 post描述异步代码。我遇到了 Async.StartChild函数,我不明白为什么
File 中有一堆相当方便的方法类,如 ReadAll***/WriteAll***/AppendAll***。 我遇到过很多情况,当我需要它们的异步对应物时,但它们根本不存在。 为什么?有什么陷阱吗
我最近开始做一个 Node 项目,并且一直在使用 async 库。我有点困惑哪个选项会更快。在某些数据上使用 async.map 并获取其结果,或使用 async.each 迭代一组用户并将他们的相应
您好,我正在试用 Springs 异步执行器,发现您可以使用 @Async。我想知道是否有可能在 @Async 中使用 @Async,要求是需要将任务委托(delegate)给 @Async 方法在第
我需要支持取消一个函数,该函数返回一个可以在启动后取消的对象。在我的例子中,requester 类位于我无法修改的第 3 方库中。 actor MyActor { ... func d
假设 asyncSendMsg不返回任何内容,我想在另一个异步块中启动它,但不等待它完成,这之间有什么区别: async { //(...async stuff...) for msg
我想用 Mocha 测试异步代码. 我跟着这个教程testing-promises-with-mocha .最后,它说最好的方法是 async/await。 以下是我的代码,我打算将 setTimeo
正如我有限(甚至错误)的理解,Async.StartImmediate 和 Async.RunSynchronously 在当前线程上启动异步计算。那么这两个功能究竟有什么区别呢?谁能帮忙解释一下?
我有一行使用await fetch() 的代码。我正在使用一些调用 eval("await fetch ...etc...") 的脚本注入(inject),但问题是 await 在执行时不会执行从ev
我正在尝试使用 nodeJS 构建一个网络抓取工具,它在网站的 HTML 中搜索图像,缓存图像源 URL,然后搜索最大尺寸的图像。 我遇到的问题是 deliverLargestImage() 在循环遍
我想结合使用 async.each 和 async.series,但得到了意想不到的结果。 async.each([1, 2], function(item, nloop) { async.s
我的代码有问题吗?我使用 async.eachSeries 但我的结果总是抛出 undefined。 这里是我的代码: async.eachSeries([1,2,3], function(data,
我想在 trait 中编写异步函数,但是因为 async fn in traits 还不被支持,我试图找到等效的方法接口(interface)。这是我在 Rust nightly (2019-01-0
async setMyPhotos() { const newPhotos = await Promise.all(newPhotoPromises); someOtherPromise();
async.js 中 async.each 与 async.every 的区别?似乎两者都相同,只是 async.every 返回结果。纠正我,我错了。 最佳答案 每个异步 .each(coll, i
我正在尝试对一组项目运行 async.each。 对于每个项目,我想运行一个 async.waterfall。请参阅下面的代码。 var ids = [1, 2]; async.each(ids,
我的目标是测试 API 调用,将延迟考虑在内。我的灵感来自 this post . 我设计了一个沙箱,其中模拟 API 需要 1000 毫秒来响应和更改全局变量 result 的值。测试检查 500
async.each 是否作为异步数组迭代工作? async.eachSeries 是否作为同步数组迭代工作?(它实际上等待响应) 我问这些是因为两者都有回调,但 async.each 的工作方式类似
我是一名优秀的程序员,十分优秀!