并行运行任务，同时保留取消任务并在一切完成后执行某些操作的选项

Question

我调用了一个异步方法，该方法又调用需要启动几个异步操作。

所有异步操作完成后，我需要通知调用者操作是完成还是取消。代码如下所示。它似乎一直有效，直到它因 FatalExecutionEngineError 而崩溃。我不会进行任何 P/invoke 或不安全的调用。

   public class Fetcher
    {
        private List<ItemsBoundToUI> uiItems;
        public async Task<bool> Fetch()
        {
            List<Task> currentlyRunningTasks = new List<Task>();


                var src = new CancellationTokenSource();


                foreach (var channel in this.uiItems)
                {
                    var task = FetchForItem(channel, src.Token);
                    currentlyRunningTasks.Add(task);
                }

            bool wasCancelled = await Task.Factory.ContinueWhenAll(currentlyRunningTasks.ToArray(),
                                                                    (s) =>
                                                                    {
                                                                        bool wasC = s.Any(ss => ss.IsCanceled);

                                                                        return wasC;
                                                                    }
                                                                    );


           return !wasCancelled;
        }

        private async Task FetchForItem(ItemsBoundToUI channel, CancellationToken src)
        {
            var subitems = await dataRepository.GetSubItemsAsync(channel.ID);

            if (src.IsCancellationRequested)
                return;
            channel.SubItems = subitems;
        }
    }

错误信息说

运行时遇到致命错误。错误的地址 位于线程 0xd94 上的 0x6c108144。错误代码为 0xc0000005。这 错误可能是 CLR 中的错​​误或不安全或不可验证的错误 部分用户代码。此错误的常见来源包括用户 COM-interop 或 PInvoke 的封送处理错误，这可能会损坏 堆栈。

如何等到所有任务都完成，或者等到它们被取消，然后返回一个值来指示它们是完成还是被取消？

Answer 1

FatalExecutionEngineError 听起来像是一个 CLR 错误。请开发一个最小的repro 并通过Microsoft Connect 向Microsoft 报告。

最好让取消按照设计的方式工作（通过例外）。要await 多个任务，请使用Task.WhenAll。

public class Fetcher
{
  private List<ItemsBoundToUI> uiItems;
  public async Task<bool> Fetch()
  {
    List<Task> currentlyRunningTasks = new List<Task>();
    var src = new CancellationTokenSource();
    foreach (var channel in this.uiItems)
    {
      var task = FetchForItem(channel, src.Token);
      currentlyRunningTasks.Add(task);
    }

    try
    {
      await Task.WhenAll(currentlyRunningTasks);
      return true;
    }
    catch (OperationCanceledException)
    {
      return false;
    }
  }

  private async Task FetchForItem(ItemsBoundToUI channel, CancellationToken src)
  {
    var subitems = await dataRepository.GetSubItemsAsync(channel.ID);
    src.ThrowIfCancellationRequested();
    channel.SubItems = subitems;
  }
}