取消異步並行代碼

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當parallelOptions參數的CancellationToken被取消

PS你應該使用一個線程安全列表/收集foundWords