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

这样我就可以在这里添加一个await运算符:

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

我怎样才能做到这一点？

PS这样我可以同时发出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());