Scrittura di metodi multithread utilizzando async/attendo in .Net 4.5

Question

Ho una piccola query.

Ammetto che non ho usato il multithreading molto prima. Net 4.5, ma con la nuova funzionalità async/await ho deciso di provarlo. Ho iniziato a sperimentarlo e tutto sembra a posto, ma non sono riuscito a trovare una soluzione per il mio "problema" in nessun punto del web.

Così tutti spiegano come await può essere utilizzato con i metodi recentemente trasformato della piattaforma .Net (ad esempio WriteAsync(), ReadAsync() ecc ...), ma se volevo usarlo per i miei metodi? Ad esempio, diciamo che sto eseguendo un calcolo estremamente costoso e voglio che tutti i miei 4 core lavorino su di esso. Avrei qualcosa di simile a questo:

async Task DoLotsOfWork<T>(T[] data, int start, int end) 
{ 
    //Do very expensive work 
} 

Ma dal momento che non ho una parola chiave await lì, il metodo è solo trattato come uno sincrono. Vorrei chiamarlo 4 volte dall'esterno in modo che possa funzionare su tutti i miei core, mentre visualizzo qualcosa di sensato all'utente (ad esempio "Please wait ..."). L'unica soluzione che sono riuscito a capire è stata l'aggiunta di await Task.Yield(); all'inizio del metodo. Qualcosa del genere:

async Task DoLotsOfWork<T>(T[] data, int start, int end) 
{ 
    await Task.Yield(); 
    //Do very expensive work 
} 

In tal caso, il metodo si comporterebbe come mi sarei aspettato. Ma c'è una soluzione migliore per questo? Sento che dovrebbe essere più facile/più ragionevole di scrivere esattamente quella riga di codice. Capisco che posso creare un oggetto Task/Thread e chiamare il metodo Start(), ma questo richiede ancora più lavoro. Ho solo pensato che con la nuova funzionalità asincrona/attesa questo genere di cose sarebbe stato più semplice.

Answer 1

Quindi, per iniziare con voi avrete bisogno di un metodo che fa il lavoro molto costoso in modo sincrono:

public void DoLotsOfWork<T>(T[] data, int start, int end) 
{ 
    Thread.Sleep(5000);//placeholder for real work 
} 

Poi possiamo usare Task.Run per avviare più istanze di questo lavoro in un thread ThreadPool.

List<Task> tasks = new List<Task>(); 
for(int i = 0; i < 4; i++) 
{ 
    tasks.Add(Task.Run(()=>DoLotsOfWork(data, start, end)); 
} 

Poi possiamo fare un'attesa non-blocking fino a quando tutti sono fatto:

await Task.WhenAll(tasks);