将 PLINQ 与 Async 方法相结合

Question

我正在尝试像这样组合我的 PLINQ 语句：

Enumerable.Range(0, _sortedList.Count()).AsParallel().WithDegreeOfParallelism(10)
          .Select(i =>  GetTransactionDetails(_sortedList[i].TransactionID))
          .ToList();

使用这样的异步方法：

 private async void GetTransactionDetails(string _trID)
 {
      await Task.Run(() =>
      {
      });
 }

这样我就可以在这里简单地添加一个等待操作符：

 Enumerable.Range(0, _sortedList.Count()).AsParallel().WithDegreeOfParallelism(10)
           .Select(i => await GetTransactionDetails(_sortedList[i].TransactionID))
           .ToList();

我怎样才能做到这一点？

附：这样我可以同时发出 5-10 个 HTTP 请求，同时确保最终用户在这样做时不会感觉到任何“屏幕”冻结...

Answer 1

您可以采取几种方法。

首先，“更正确”的方法（这也是更多的工作）。将GetTransactionDetails 变成正确的async 方法（即不使用Task.Run）：

private async Task GetTransactionDetailsAsync(string _trID);

然后你可以同时调用那个方法：

var tasks = _sortedList.Select(x => GetTransactionDetailsAsync(x.TransactionID));
await Task.WhenAll(tasks);

如果您需要限制并发，请使用SemaphoreSlim。

第二种方法更浪费（在线程使用方面），但考虑到我们已经看到的代码部分，可能更容易。第二种方法是让 I/O 保持同步，并以常规 PLINQ 方式进行：

private void GetTransactionDetails(string _trID);

_sortedList.AsParallel().WithDegreeOfParallelism(10).Select(x => GetTransactionDetails(x.TransactionID)).ToList();

为避免阻塞 UI 线程，您可以将其包装在单个 Task.Run 中：

await Task.Run(() => _sortedList.AsParallel().WithDegreeOfParallelism(10).Select(x => GetTransactionDetails(x.TransactionID)).ToList());