将 async lambda 包装到 async 方法

Question

我正在尝试将我的 Operations Contracts 包装到 try-catch 块中。问题是我的 EF 上下文在同一时间范围内被破坏。我猜问题编译器不知道该怎么做。我的 catch 块也不处理任何异常。对不起我的英语，我希望我的代码能说明我的意思：

private static async Task<T> SurroundWithTryCatch<T>(Action t, T response) where T : BaseResponse 
{
    try
    {
        await Task.Run(t);
    }
    catch (Exception e)
    {
        response.Success = false;
        response.Errors.Add(e.Message);
    }
    return response;
}

public async Task<CreateResponse> CreateAsync(CreateRequest request)
{
    var response = new CreateResponse();
    return await SurroundWithTryCatch(async delegate
    {
        var newUser = new ApplicationUser { UserName = request.UserName, Email = request.Email };
        await Database.UserManager.CreateAsync(newUser, request.Password);
        //Some another logic...
        await Database.CommitAsync();
    }, response);
}

CreateAsync方法第二行的问题。 UserManager 之前被 GC 清理过。所以我有ObjectDisposedException。 Database 是IUnitOfWork 的实现，由Autofac 注入。

Answer 1

你打破了await 链 - t 不再返回任务。由于您不再有任务，因此将在第一个 await 之后继续执行，而不是在整个方法完成之后。将await 视为return - 如果您不返回（和await/等待）任务，您将失去同步的机会。

相反，您想传递Func<Task>，并直接等待它：

private static async Task<T> SurroundWithTryCatch<T>(Func<Task> t, T response) where T : BaseResponse 
{
    try
    {
        await t();
    }
    catch (Exception e)
    {
        response.Success = false;
        response.Errors.Add(e.Message);
    }
    return response;
}

public async Task<CreateResponse> CreateAsync(CreateRequest request)
{
    var response = new CreateResponse();
    return await SurroundWithTryCatch(async () =>
    {
        var newUser = new ApplicationUser { UserName = request.UserName, Email = request.Email };
        await Database.UserManager.CreateAsync(newUser, request.Password);
        //Some another logic...
        await Database.CommitAsync();
    }, response);
}

Task.Run 也可以，但你可能不希望这样 - 你的代码是异步的，并且（猜测）你在 ASP.NET 请求中运行，所以启动一个任务只是为了等待另一个任务的结果。 Task.Run 用于在单独的线程中执行 CPU 工作，这在 ASP.NET 中通常要避免。