将 PLINQ 与异步方法相结合

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(() =>
      {
      });
 }

这样我就可以简单地在此处添加一个 await 运算符：

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

我怎样才能做到这一点？

P.S。这样我可以同时发出 5-10 个 HTTP 请求，同时确保最终用户在这样做时不会感到任何 "screen" 冻结...

Answer 1

您可以采用几种方法。

首先，"more correct" 方法（也需要更多工作）。使 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());

将 PLINQ 与异步方法相结合

Combining PLINQ with Async method

c#

asynchronous

plinq

winforms

c#-4.0