查找并行异步任务的结果

Question

基于this question，我正在尝试设置代码以将多个图像并行保存到 Azure Blob 存储。下面的这个方法工作正常，等待 Task.WhenAll(tasks) 在继续之前等待所有完成。

唯一的麻烦是，我希望能够查明每个将信息存储在我们数据库中的请求是否真的成功了。 _db.AddImageAsync 返回一个布尔值，下面的代码等待所有任务完成，但是当我检查所有任务的结果时，每个任务都是假的（即使我实际上在括号内返回了真）。

Enumerable 中的每个任务都表示尚未计算结果，即使我通过断点逐步执行并且每个任务都已执行。

  var tasks = wantedSizes.Select(async (wantedSize, index) =>
  {
    var resize = size.CalculateResize(wantedSize.GetMaxSize());
    var quality = wantedSize.GetQuality();

    using (var output = ImageProcessHelper.Process(streams[index], resize, quality))
    {
        var path = await AzureBlobHelper.SaveFileAsync(output, FileType.Image);
        var result = await _db.AddImageAsync(id, wantedSize, imageNumber, path);
        return result;
    }
  });

  await Task.WhenAll(tasks)

  if (!tasks.All(task => task.Result))
      return new ApiResponse(ResponseStatus.Fail);

非常感谢任何帮助！

Answer 1

因为.Select( 是惰性求值并返回IEnumerable<Task<bool>>，所以当您多次迭代结果时，会导致.Select( 运行多次。在其上抛出.ToList() 使其成为List<Task<bool>>，并且只会执行一次.Select(，并且多个枚举将超过返回的List<Task<bool>>，不会产生副作用。

  var tasks = wantedSizes.Select(async (wantedSize, index) =>
  {
    var resize = size.CalculateResize(wantedSize.GetMaxSize());
    var quality = wantedSize.GetQuality();

    using (var output = ImageProcessHelper.Process(streams[index], resize, quality))
    {
        var path = await AzureBlobHelper.SaveFileAsync(output, FileType.Image);
        //Double check your documentation, is _db.AddImageAsync thread safe?
        var result = await _db.AddImageAsync(id, wantedSize, imageNumber, path);
        return result;
    }
  }).ToList(); //We run the Select once here to process the .ToList().

  await Task.WhenAll(tasks) //This is the first enumeration of the variable "tasks".

  if (!tasks.All(task => task.Result)) //This is a 2nd enumeration of the variable.
      return new ApiResponse(ResponseStatus.Fail);