Date le capacità dei computer attuali, capita spesso di trovarsi a parallelizzare una serie di operazioni, attendere che queste abbiano concluso, lavorare sul risultato e restituirlo. Fare tutto questo non è però banale, perché richiede l'utilizzo di più thread (per eseguire più operazioni concorrenti) e attendere che questi abbiano finito, ma fortunatamente viene in aiuto la Task Parallel Library che semplifica notevolmente la realizzazione di questi scenari.
Ipotizzando di voler scaricare più pagine HTML con richieste HTTP, la TPL offre dei metodi di factory per rappresentare i Task che vogliamo eseguire. Una volta definiti, questi possono essere avviati o relazionati con altri task. Nello snippet seguente si crea un task per ogni WebRequest da utilizzare per effettuare la richiesta HTTP; attraverso poi Task.WaitAll si avvia e si attende che questi vengano eseguiti.
// Lista degli uri da caricare Uri[] uris = new Uri[] { new Uri("https://www.winfxitalia.com"), new Uri("https://www.aspitalia.com") }; List<Task<WebResponse>> tasks = new List<Task<WebResponse>>(); foreach (Uri u in uris) { // Preparo la richiesta HTTP da fare HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(u); request.UserAgent = "Test"; // Rappresento il task di avvio della richiesta Task<WebResponse> task = Task.Factory.FromAsync((c, s) => request.BeginGetResponse(c, s), ar => request.EndGetResponse(ar), TaskCreationOptions.LongRunning); tasks.Add(task); } // Eseguto e aspetto che tutti i task abbiano finito Task.WaitAll(tasks.ToArray()); WebResponse[] response = tasks.Select(t => t.Result).ToArray();
Il factory method FromAsync permette di rappresentare operazioni che rispettano il pattern Begin/End, ma è possibile anche passare una normale funzione sincrona. L'esempio può essere ampliato facendo in modo che, dopo l'esecuzione di ogni task, ne venga eseguito uno che gestisca i risultati e restituisca l'HTML di ogni richiesta. Il metodo ContinueWhenAll soddisfa questa esigenza, permettendo di passare il delegate da eseguire per processare il risultato.
Task htmlTask = Task.Factory.ContinueWhenAll<WebResponse, String[]>(tasks.ToArray(), DownloadFinished); htmlTask.Wait(); string[] html = htmlTask.Result; static String[] DownloadFinished(Task<WebResponse>[] tasks) { return tasks.Select(t => { using (Stream s = t.Result.GetResponseStream()) { return new StreamReader(s).ReadToEnd(); } }).ToArray(); }
E' importante notare che i task vengono eseguiti secondo le logiche dello scheduler, su thread secondari, a seconda dei carichi della macchina, dei tempi di risposta delle richieste e della capacità della CPU. Non si può prevedere con esattezza quante richieste in parallelo effettua, ma si può contare sul fatto che lo scheduler tende a sfruttare al massimo le capacità della macchina.
Commenti
Per inserire un commento, devi avere un account.
Fai il login e torna a questa pagina, oppure registrati alla nostra community.
Approfondimenti
Ottimizzare il mapping di liste di tipi semplici con Entity Framework Core
Effettuare il binding di date in Blazor
Gestire undefined e partial nelle reactive forms di Angular
Elencare le container images installate in un cluster di Kubernetes
Utilizzare l'operatore GroupBy come ultima istruzione di una query LINQ in Entity Framework
Usare le variabili per personalizzare gli stili CSS
Controllare gli accessi IP alle app con Azure Container Apps
Utilizzare domini personalizzati gestiti automaticamente con Azure Container Apps
Autenticarsi in modo sicuro su Azure tramite GitHub Actions
Eseguire query manipolando liste di tipi semplici con Entity Framework Core
Eseguire un metodo asincrono dopo il set di una proprietà in Blazor 8
Semplificare il deployment di siti statici con Azure Static Web App
I più letti di oggi
- Microsoft annuncia Windows "TrustBridge"
- ASP.NET 4.0 in practice
- Migrare una service connection a workload identity federation in Azure DevOps
- ASP.NET 4.0 in C# e VB
- ecco tutte le novità pubblicate sui nostri siti questa settimana: https://aspit.co/wkly buon week-end!
- Sblocca le performance della tua applicazione con .NET 8