Come scrivere correttamente Parallel.Per metodi asincroni

Question

Come strutturare il codice qui sotto in modo che venga richiamato il metodo asincrono?

Parallel.For(0, elevations.Count(), delegate(int i) 
{ 
    allSheets.AddRange(await BuildSheetsAsync(userID, elevations[i], includeLabels)); 
}); 

Answer 1

Parallel.For() non funziona bene con async metodi. Se non è necessario limitare il grado di parallelismo (vale a dire che stai bene con tutte le attività che eseguono allo stesso tempo), si può semplicemente avviare tutti i Task s e poi aspettare per loro di completare:

var tasks = Enumerable.Range(0, elevations.Count()) 
    .Select(i => BuildSheetsAsync(userID, elevations[i], includeLabels)); 
List<Bitmap> allSheets = (await Task.WhenAll(tasks)).SelectMany(x => x).ToList(); 

Answer 2

vi consiglio di dare un'occhiata a questa domanda ho chiesto un paio di giorni fa e finito-up me rispondere, in fondo ero alla ricerca di un metodo ForEach parallelo e asincrona.

Il metodo utilizza SemaphoreSlim per elaborare le cose in parallelo e accetta metodi asincroni come azione di input.

Si potrebbe anche voler dare un'occhiata ai due collegamenti che ho fornito alla fine della mia risposta, sono stati davvero utili per la realizzazione di tale comportamento e contengono anche un altro modo di farlo utilizzando uno Partitioner invece.

Personalmente, non mi piaceva il Parallel.For perché è una chiamata sincrona come spiegato nei collegamenti che ho dato; Volevo tutto 'asincrono' :-)

Eccolo: Asynchronously and parallelly downloading files

Answer 3

il modo più semplice per invocare il metodo asincrono all'interno Parallel.For è prossimo:

Parallel.For(0, elevations.Count(), async i => 
{ 
    allSheets.AddRange(await BuildSheetsAsync(userID, elevations[i], includeLabels)); 
}); 

==============

MarioDS menzionato assolutamente ragione nel commento che in In tal caso potresti avere eccezioni inosservate. E questa è sicuramente una cosa molto importante che dovresti sempre tenere a mente e avere un accordo con i delegati asincroni.

In questo caso, se si ritiene di avere eccezioni, è possibile utilizzare il blocco try/catch all'interno del delegato. O in alcuni casi, se la situazione è buona, puoi iscriverti all'evento TaskScheduler.UnobservedTaskException.