Объединения 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-запросов одновременно, гарантируя, что конечный пользователь не чувствует «замораживания» экрана при этом ...

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(); 

Чтобы избежать блокирования потока пользовательского интерфейса, вы можете обернуть это в одном Task.Run:

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