Отменить асинхронный параллельный код

Question

Учитывая следующий пример:

private async Task<List<string>> SearchStrings(string text, ImmutableList<string> words, CancellationToken token) { 
     var foundWords = new List<string>(words.Count); 
     var result = await Task.Run(() => 
      Parallel.ForEach(words, (s) => { 
       if (s.ToLower().Contains(text)) { 
        foundWords.Add(s); 
       } 
      })); 
     return foundWords; 
    } 

Что я должен отменить с моим маркером? Это задача, параллельное выполнение или и то, и другое? И где я должен поймать это исключение?

Answer 1

Пропускают CancellationToken к задаче и петля, как показано ниже:

private async Task<List<string>> SearchStrings(string text, ImmutableList<string> words, CancellationToken token) { 
    var foundWords = new List<string>(words.Count); 
    var result = await Task.Run(() => 
     Parallel.ForEach(words, new ParallelOptions { CancellationToken = token, }, (s) => { 
      if (s.ToLower().Contains(text)) 
      { 
       foundWords.Add(s); 
      } 
     }), token); 
    return foundWords; 
} 

• Task.Run(Action action, CancellationToken token)

  Если отмена запрашивается до того, как задача начинает выполнение, задача не выполнить. Вместо этого он устанавливается в состояние Canceled и генерирует исключение TaskCanceledException.

• Parallel.ForEach<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Action<TSource> body)

  Броски OperationCanceledException когда CancellationToken в parallelOptions аргумент аннулируется

PS Вы должны использовать Потокобезопасная список/коллекция для foundWords