同时执行所有任务并等待完成？

Question

我有一系列我想同时执行的异步方法。这些方法中的每一个都会返回true或false，以确定它们是否成功执行。他们的结果也记录在我们的审计线索中，以便我们可以诊断问题。

我的一些函数并不依赖于所有这些方法的执行成功，我们完全期望其中的一些方法会不时失败。如果他们确实失败了，该计划将继续执行，只会提醒我们的支持人员他们需要纠正问题。

我想弄清楚什么是所有这些功能同时执行的最佳方法，但只有在它们全部开始执行后，父功能才会等待它们。如果任何函数失败，父函数将返回False，这将提醒我的应用程序停止执行。

我的想法是做类似的东西：

public async Task<bool> SetupAccessControl(int objectTypeId, int objectId, int? organizationId) 
{ 
    using (var context = new SupportContext(CustomerId)) 
    { 
     if (organizationId == null) 
     { 
      var defaultOrganization = context.Organizations.FirstOrDefault(n => n.Default); 
      if (defaultOrganization != null) organizationId = defaultOrganization.Id; 
     } 
    } 

    var acLink = AcLinkObjectToOrganiation(organizationId??0,objectTypeId,objectId); 

    var eAdmin = GrantRoleAccessToObject("eAdmin", objectTypeId, objectId); 
    var defaultRole = GrantRoleAccessToObject("Default", objectTypeId, objectId); 

    await acLink; 
    await eAdmin; 
    await defaultRole; 

    var userAccess = (objectTypeId != (int)ObjectType.User) || await SetupUserAccessControl(objectId); 

    return acLink.Result && eAdmin.Result && defaultRole.Result && userAccess; 
} 

public async Task<bool> SetupUserAccessControl(int objectId) 
{ 
    var everyoneRole = AddToUserRoleBridge("Everyone", objectId); 
    var defaultRole = AddToUserRoleBridge("Default", objectId); 

    await everyoneRole; 
    await defaultRole; 

    return everyoneRole.Result && defaultRole.Result; 
} 

是否还有更好的选择吗？我应该以任何方式重组吗？我只是试图加快执行时间，因为我有一个父函数可以执行接近20个彼此独立的其他函数。即使速度最慢，没有异步，执行只需要大约1-2秒。然而，这将被放大以最终使该父呼叫执行数百次（批量插入）。

Answer 1

异步方法有一个同步部分，它是在未完成任务的第一个等待之前到达的部分（如果没有一个则整个方法同步运行）。该部分使用调用线程同步执行。

如果要同时运行这些方法而不平行化这些部分，只需调用方法，收集任务并使用Task.WhenAll一次等待所有这些方法。当所有任务完成后，您可以检查各个结果：

async Task<bool> SetupUserAccessControlAsync(int objectId) 
{ 
    var everyoneRoleTask = AddToUserRoleBridgeAsync("Everyone", objectId); 
    var defaultRoleTask = AddToUserRoleBridgeAsync("Default", objectId); 

    await Task.WhenAll(everyoneRoleTask, defaultRoleTask) 

    return await everyoneRoleTask && await defaultRoleTask; 
} 

如果你想并行化同步部分，以及你需要多线程等等，而不是简单地调用异步方法，使用Task.Run卸载到ThreadPool线程：

async Task<bool> SetupUserAccessControlAsync(int objectId) 
{ 
    var everyoneRoleTask = Task.Run(() => AddToUserRoleBridgeAsync("Everyone", objectId)); 
    var defaultRoleTask = Task.Run(() => AddToUserRoleBridgeAsync("Default", objectId)); 

    await Task.WhenAll(everyoneRoleTask, defaultRoleTask) 

    return await everyoneRoleTask && await defaultRoleTask; 
} 

如果所有方法都返回bool您可以收集所有的任务列表中，从Task.WhenAll得到的结果，并检查是否所有返回true：

async Task<bool> SetupUserAccessControlAsync(int objectId) 
{ 
    var tasks = new List<Task<bool>>(); 
    tasks.Add(AddToUserRoleBridgeAsync("Everyone", objectId)); 
    tasks.Add(AddToUserRoleBridgeAsync("Default", objectId)); 

    return (await Task.WhenAll(tasks)).All(_ => _); 
}