La combinaison PLINQ avec la méthode Async

Question

J'essaie de combiner ma déclaration de PLINQ comme ceci:

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

Avec une méthode async comme ceci:

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

Alors que je peux simplement ajouter un opérateur await ici:

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

Comment puis-je y parvenir?

P.S. De cette façon, je pouvais faire 5-10 requêtes HTTP simultanément tout en veillant à ce que l'utilisateur final ne se sent pas de gel « écran » en le faisant ...

Answer 1

Il y a deux approches que vous pouvez prendre.

D'abord, l'approche « plus correcte » (qui est aussi plus de travail). Faire GetTransactionDetails dans une méthode async appropriée (à savoir, ne pas utiliser Task.Run):

private async Task GetTransactionDetailsAsync(string _trID); 

Ensuite, vous pouvez appeler cette méthode simultanément:

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

Si vous devez limiter la concurrence, utilisez un SemaphoreSlim.

La seconde approche est plus inutile (en termes d'utilisation de fil), mais il est probablement plus facile étant donné que les parties de votre code que nous avons vu. La seconde approche est de laisser les E/S tout synchrone et faites-le de façon régulière PLINQ:

private void GetTransactionDetails(string _trID); 

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

Pour éviter de bloquer le thread d'interface utilisateur, vous pouvez envelopper cela dans un seul Task.Run:

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