合并不同类型的 .NET 4.0 任务/延续

Question

我目前正在实现一个System.Web.Http.IActionFilter，它调用一个内部服务来确定当前请求是否可以继续。我遇到的问题是根据Task<T2> 封装的一段逻辑返回Task<T1>。

一个例子可能会有所帮助。

内部服务 API 是使用 Tasks 实现的。使用 .NET 4.5 的 async/await 的逻辑很简单：

public async Task<HttpResponseMessage> ExecuteActionFilterAsync(HttpActionContext actionContext, CancellationToken cancellationToken, Func<Task<HttpResponseMessage>> continuation)
{
    UserAuthenticationResult authResult = await HitInternalServiceAsync();

    if (!authResult.IsAuthenticated)
    {
        throw new HttpResponseException("User is not authenticated", HttpStatusCode.Unauthorized);
    }

    return await continuation();
}

但是在 .NET 4.0 中使用旧的 Task API 会更加困难；

public Task<HttpResponseMessage> ExecuteActionFilterAsync(HttpActionContext actionContext, CancellationToken cancellationToken, Func<Task<HttpResponseMessage>> continuation)
{
    return HitInternalServiceAsync()
            .ContinueWith(t1 => {
                UserAuthenticationResult authResult = t1.Result;

                if (!authResult.IsAuthenticated)
                {
                    throw new HttpResponseException("User is not authenticated", HttpStatusCode.Unauthorized);
                }

                //Hack hack - this blocks the thread until the task retuned by continuation() completes
                return continuation().Result;
            });
}

当身份验证检查成功时，困难的部分就来了——然后我想等待延续函数返回的任务。

使用 .NET 4.0 时，我似乎在等待 continuation() 任务完成时明确阻止，而不是在 我的任务时指示 Tasks API 自动继续 continuation() 任务完成了。

问题：这是在 .NET 4.0 中实现此行为的唯一方法吗？

给定一个足够复杂的内部服务 API，我可以很容易地看到等待其他任务的任务数量迅速增加。

编辑： 看起来上面的 4.0 代码也不可行 - 因为延续 lambda 不会在 HttpContext.Current 等 ASP.NET 线程上下文服务中执行不可用。更好的实现是......

public Task<HttpResponseMessage> ExecuteActionFilterAsync(HttpActionContext actionContext, CancellationToken cancellationToken, Func<Task<HttpResponseMessage>> continuation)
{
    Task<UserAuthenticationResult> authResultTask = HitInternalServiceAsync();

    var authResult = authResultTask.Result;

    if (!authResult.IsAuthenticated)
    {
        throw new HttpResponseException("User is not authenticated", HttpStatusCode.Unauthorized);
    }

    return continuation();
}

Answer 1

您的问题是，如果您不使用Result，ContinueWith() 将返回Task<Task<HttpResponseMessage>>，而不是您需要的Task<HttpResponseMessage>。

幸运的是，已经有一种方法可以将任何Task<Task<T>> 转换为Task<T>：Unwrap()。所以只需 return continuation(); 来自 ContinueWith() lambda，然后在结果上调用 Unwrap()。

如果您希望继续在 ASP.NET 上下文中执行，可以使用TaskScheduler.FromCurrentSynchronizationContext()。

Answer 2

问题：这是在 .NET 4.0 中实现此行为的唯一方法吗？

async/await 是 C# 5.0 功能，而不是 .NET 4.5 功能。它确实使用了 .NET 4.5 中引入的某些类型，但没有其他原因需要新的运行时。

如果您使用的是 VS2010 (C# 4.0)，svick 的答案是最好的。

但是，如果您使用的是 VS11 Beta (C# 5.0)，还有另一种选择：您可以使用 async targeting pack 编写在 .NET 4.0 上运行的 async/await 代码。目标包具有 .NET 4.0 的这些新类型。

Answer 3

而不是 continuation().Result 使用 continuation().Wait()

task.wait 是阻止任务的适当方式。

根据 MSDN 文档， Task.Wait 方法：等待Task完成执行。

http://msdn.microsoft.com/en-us/library/dd235635.aspx

以下似乎相关的问题，即答案 Do the new C# 5.0 'async' and 'await' keywords use multiple cores?