在我的服务器上,我有一条为用户生成pdf的路由。当生成时间超过指定的时间量时,该路由应返回已接受的状态代码,并在处理完成时向用户发送电子邮件。我遇到的问题是Task.Delay
没有得到尊重。无论我设置PdfGenerationTimeLimitUntilEmail
有多低,Wait.Any
仍然无法解决,直到createPdfTask
完成。有趣的是,当生成抛出异常或完成,并且时间已经超过Task.Delay
时间时,执行继续返回“已接受状态”。我怀疑罪魁祸首是死锁情况。
一个相关的问题,我已经彻底阅读,但未能适用于我的问题:C#/.NET 4.5 - Why does "await Task.WhenAny" never return when provided with a Task.Delay in a WPF application's UI thread?
我有什么遗漏吗?或者我应该知道的线程上下文?
[HttpPost]
[Route("foo")]
public async Task<IHttpActionResult> Foo([FromBody] FooBody fooBody)
{
var routeUser = await ValidateUser();
async Task<Stream> CeatePdfFile()
{
var pdf = await createPdfFromFooData(fooBody);
return await pdfFileToStream(pdf);
}
var delay = Task.Delay(PdfGenerationTimeLimitUntilEmail);
var createPdfTask = CeatePdfFile();
var firstTaskResolved = await Task.WhenAny(createPdfTask , delay);
if (firstTaskResolved == createPdfTask)
{
var pdfFileStream = await createPdfTask ;
return new FileActionResult(pdfFileStream);
}
// Creating the PDF can take a long time, so just send an email when it's done
async void SendEmail(CancellationToken token)
{
var pdfFileStreamToEmail = await createPdfTask ;
_emailSender.SendDownloadEmail(routeUser.Email, pdfFileStreanToEmail);
}
HostingEnvironment.QueueBackgroundWorkItem(token => SendEmail(token));
return StatusCode(HttpStatusCode.Accepted);
}
如果Kevin Gosse是正确的,那么真正的问题是createPdfFromFooData
和CeatePdfFile
在第一个await
之前做了很多工作:你可以添加一个Task.Yield()
来人工强制额外的等待,基本上将其余的工作推到工作队列对于相关上下文(或线程池,否则):
async Task<Stream> CeatePdfFile()
{
await Task.Yield(); // force asynchronicity
var pdf = await createPdfFromFooData(fooBody);
return await pdfFileToStream(pdf);
}