取消 Parallel.ForEach 或使用异步等待

Question

我有这个活动：

private void  TextBoxSearchText_TextChanged(object sender, TextChangedEventArgs e)
{
    searchText();
}

我想取消这个并行方法并在文本框文本更改时开始一个新的方法，并且还希望我的文本框能够响应我的新文本输入，在结果进入列表框之前锁定。

List<TextList> oSelected;
private void searchText()
{
string strSearchText = TextBoxSearchText.Text;
    oSelected = new List<TextList>();            
    Parallel.ForEach(oTextList, item  =>
    {
        Match myMatch = Regex.Match(item.EnglishText.ToString(), "\\b" + strSearchText.ToString().ToLower() + @"\w*", RegexOptions.IgnoreCase);
        if (!myMatch.Success)
        {
            return;
        }

        oSelected.Add(new TextList
        {
            Id = item.Id,
            EnglishText = item.EnglishText
        });
    });

    ListBoxAllTexts.ItemsSource = oSelected;
}

是否可以使用 async 和 awiat 来完成这项工作？ 哪一个更适合在近 100 万行文本中搜索文本？ 我读了很多关于 async 和 await 但我不明白如何在我的工作中使用它。 谢谢

Answer 1

由于您的工作受 CPU 限制，因此您应该使用并行代码来进行实际搜索。但是，您可以使用Task.Run 将并行工作封装在async/await 思维模式中：

private async void TextBoxSearchText_TextChanged(object sender, TextChangedEventArgs e)
{
  ListBoxAllTexts.ItemsSource = await Task.Run(() => searchText(TextBoxSearchText.Text));
}

这将使您的 UI 保持响应。

要取消，use a CancellationTokenSource。附带说明一下，您无法像当前尝试那样从并行循环中更新List<T>，因为List<T> 不是线程安全的。在这种情况下，我建议您改用 PLINQ：

private CancellationTokenSource _cts;
private async void TextBoxSearchText_TextChanged(object sender, TextChangedEventArgs e)
{
  if (_cts != null)
    _cts.Cancel();
  _cts = new CancellationTokenSource();
  var strSearchText = TextBoxSearchText.Text;
  ListBoxAllTexts.ItemsSource = await Task.Run(
      () => searchText(strSearchText, _cts.Token));
}

private List<TextList> searchText(string strSearchText, CancellationToken token)
{
  try
  {
    return oTextList.AsParallel().WithCancellation(token)
        .Where(item => Regex.IsMatch(item.EnglishText.ToString(), "\\b" + strSearchText.ToLower() + @"\w*", RegexOptions.IgnoreCase))
        .Select(item => new TextList
        {
          Id = item.Id,
          EnglishText = item.EnglishText
        })
        .ToList();
  }
  catch (OperationCanceledException)
  {
    return null;
  }
}

另外，考虑通过延迟后才开始搜索来限制用户输入。 Rx 是最好的方法。