将异步等待集成到同步方法中

Question

我已经用头撞墙两天了，坦率地说，我对自己很生气，因为我似乎无法明白。

我在webapi 上下文中。在这个请求期间，我需要向我们的其他系统之一发送一些数据，由于计算量大和多个数据库保存等原因，这个系统返回缓慢。我需要记录这个操作的结果，无论它是否成功或不。但我不想等待它完成。

我有read，我应该从上到下一直是async await。如果我决定这样做，我将不得不转换许多方法，因为我已经深入了 3 或 4 种方法，我担心会扩展更多。

我在这里有什么选择？如果我一直异步等待，我该怎么处理堆栈中更高的方法，比如我的 WebApi 控制器？

这是我的代码，我已经尽可能地精简它。现在我在方法PushResult() 中使用Task.Result()。我的理解是阻止异步？此代码在发送请求时起作用。但是 TestLog 总是最后的，而不是第一个。因此不是异步的。

    //I'm in a public service and referenced twice
    private void MyEndProcess()
    {
        // other stuff

        _vendorPushService.PushResult(); // This could take a while and I have to wait for it!

        _logService.PostLog(LogType.TestLog, "Test");
    }

    //I'm referenced above and somewhere else in the code base
    public void PushResult()
    {   
        ExternalResultModel externalResultModel = _resultService.GetExternalResultModel();

        PushedResultModel pushedResult = new PushedResultModel();

        try
        {
            pushedResult = _vendorRequestService.PushResultAsync(externalResultModel).Result;
        }
        catch (Exception ex)
        {
            pushedResult.Success = false;
        }

        if (pushedResult.Success)
        {
            _logService.PostLog(LogType.SuccessLog, pushedResult.Message);
        }
        else
        {
            _logService.PostLog(LogType.FailedLog, pushedResult.Message);
        }
    }

    public async Task<PushedResultModel> PushResultAsync(ExternalResultModel externalResultModel)
    {
        // setup the requestMessage
        HttpResponseMessage responseMessage = await _httpRequestService
            .SendRequest(requestMessage)
            .ConfigureAwait(false);

        return new PushedResultModel
        {
            Success = responseMessage.IsSuccessStatusCode,
            Message = await responseMessage.Content.ReadAsStringAsync()
        };
    }

    public class HttpRequestService : IHttpRequestService
    {
        private readonly HttpClient _httpClient; 

        public HttpRequestService(IHttpClientAccessor httpClientAccessor)
        {
            _httpClient = httpClientAccessor.HttpClient;
        }

        public async Task<HttpResponseMessage> SendRequest(HttpRequestMessage requestMessage)
        {
            HttpResponseMessage httpResponseMessage = await _httpClient.SendAsync(requestMessage).ConfigureAwait(false);

            return httpResponseMessage;
        }
    }

Answer 1

您应该从上到下一直实现异步等待。

如果我一直使用 async await，我该如何处理堆栈中更高的方法，比如我的 WebApi 控制器？

只需像这样使您的控制器操作异步：

[RoutePrefix("api")]
public class PresidentsController : ApiController
{
    [Route("presidents")]
    public async Task<IHttpActionResult> GetPresidents()
    {
        await Task.Delay(TimeSpan.FromSeconds(10)).ConfigureAwait(false);
        return Ok();
    }
}

这是实现异步方法的最简单方法。即使它会增加一些工作以将所有内容更改为异步，它也会在未来受益，因为您将避免异步代码的许多问题。

如果您绝对必须在同步方法中使用异步方法，请将其阻塞在一个地方，如下所示：

public void MySyncMethod()
    {
        try
        {
            this.MyAsyncMethod().Wait();

        }
        catch (Exception exception)
        {
            //omited
        }
    }
private async Task MyAsyncMethod()
{
     await AsyncLogic().ConfigureAwait(false);
}

但我不推荐它。您应该一直使用 async await 到控制器操作。

Answer 2

在您的评论中，您说您希望在后台处理任务，而不是让调用您的 API 的客户端等待。为此，您实际上并不需要使用 async/await。

试试这个：

private void MyEndProcess()
{
    // other stuff

    Task.Run(_vendorPushService.PushResult()).ConfigureAwait(false); //fire and forget

    _logService.PostLog(LogType.TestLog, "Test");
}

Task.Run 将启动任务，ConfigureAwait(false) 告诉它它不需要在我们当前所在的同一上下文中恢复（这意味着上下文可以在任务完成之前关闭 - 即可以在不等待任务完成的情况下发回响应。

您将收到一个编译器警告，提示您没有在等待 Task.Run，但这正是您想要的。

请记住，当您执行此操作时，HttpContext.Current 将无法在 PushResult 中使用。