用于数据库调用的并行 Foreach 与异步 Foreach

Question

我有一个场景，我必须为列表中的每个项目调用相同的数据库存储过程。我不想使用 foreach，因为它会降低性能，哪个是并行 foeach 或 async/await foreach 的最佳选择？

下面是示例代码

public Task<List<object>> CallMethod()
{
    foreach(var obj in input)
    {
        List.Add(await Task.Run(() =>CallDatabase(obj)));
    }
   return List;
}

public CallDatabase(object)
{
    //Code to call DB 
}

从 DB 接收到的所有对象都是独立的。

经过一些研究，我计划使用异步调用，这会提高性能吗？

Answer 1

我已经实施了一个解决方案；不确定这个异步是否会提高性能，我对异步很陌生，所以不太清楚。

 public static async Task<List<Response>> Execute(Request objInput)
 {
       List<Response> objList = new List<Response>();
       foreach (object obj in objInput.objs)
        {
            objList.Add(await Task.Run(() =>GetDataFromDB(obj)));
        }
  return objList;
 }


  private static object GetDataFromDB(object obj)
  {
       //Call DB and build the object
  }

如果这不是实现异步的正确方法，请提供其他想法。

Answer 2

这主要是对D Stanley's answer 的评论——切换到并行/异步代码不太可能提高性能。

如果您主要关心的是响应性/可扩展性 - 异步会更好，因为通常数据库访问是 IO 绑定操作。它还允许在顺序处理和并行处理之间进行选择（即，如果您的 DB 层由于某种原因不支持同一连接上的并发请求）。此外，使用async，如果您使用默认同步上下文，则更容易获得正确的同步以更新 UI/请求。

顺序：它将与非异步解决方案一样长，但线程可以同时执行其他活动（对于 WinForms/WPF 等 UI 应用程序）或处理请求 (ASP.Net)。

async public Task<ResultType> CallMethodAsync()
{
    foreach(var obj in input)
    {
        var singleResult = await CallDatabaseAsync(obj);
        // combine results if needed
    }
    // return combined results    
}

并行：将同时运行所有请求，可能比顺序解决方案更快。

async public Task<ResultType> CallMethodAsync()
{
    List<Task<SingleResultType>> tasks = new List<Task<SingleResultType>>();
    foreach(var obj in input)
    {
        tasks.Add(await CallDatabaseAsync(obj));
    }
    await Task.WhenAll(tasks);

    foreach(SingleResultType result in tasks.Select(t=>t.Result))
    {
        // combine results if needed
    }
    // return combined results    
}

请注意，async 通常要求您的所有代码都是异步的 - 因此，如果您将一小段代码转换为并行运行，Parallel.ForEach 可能是更简单的解决方案，因为它不涉及处理 await vs Task.Wait - Deadlock?。

Answer 3

我不确定这是否会有所不同。我假设您仍然需要等待加载所有结果，在这种情况下async 没有帮助，您的瓶颈很可能是网络 I/O 和服务器处理而不是本地 CPU，所以并行性也无济于事。

也就是说，如果您不需要查询结果并且不在乎是否有错误，那么async 可能会在“即发即弃”的情况下有所帮助。

您最大的收获可能是尝试在一个查询中获得多个结果，而不是触发一堆单独的查询。

Answer 4

绝对是Async，因为Parallel.ForEach 用于计算密集型操作。它分布在可用的核心资源上并相应地编排它们。相反，异步仅用于此类操作：向服务发出请求，然后在之前请求的资源可用时继续并接收通知。