Lezioni

Analizziamo l’avvio e la composizione di calcoli asincroni con CompletableFuture: come avviare attività tramite supplyAsync e runAsync, in cosa differiscono gli handler thenApply, thenAccept, thenRun e quando scegliere le loro versioni asincrone thenApplyAsync/ thenAcceptAsync/ thenRunAsync. Parleremo dei thread di esecuzione ( ForkJoinPool o un tuo Executor), dei tipi di risultato ( CompletableFuture<T>, CompletableFuture<Void>) e degli errori tipici: chiamate bloccanti get()/ join(), errori non gestiti senza exceptionally/ handle/ whenComplete, nonché il tentativo di usare il risultato all’interno di thenRun.

Come parallelizzare le attività e unire i risultati con CompletableFuture: unione di due risultati tramite thenCombine/ thenCombineAsync, attesa di un insieme di attività tramite allOf, reazione alla risposta più veloce tramite anyOf. Analizzeremo le firme, esempi pratici con supplyAsync, l’elaborazione non bloccante ( thenAccept, thenRun), nonché le sottigliezze degli errori e la loro gestione ( exceptionally, handle, whenComplete). Alla fine — una tabella compatta di confronto dei metodi.

Come intercettare e gestire in modo sicuro le eccezioni nelle catene CompletableFuture: analizziamo i ruoli di exceptionally (valore di fallback in caso di errore), handle (gestore universale di successo/errore) e whenComplete (azioni collaterali senza modificare il risultato). Discuteremo perché la chiamata diretta a get()/ join() incapsula le cause in ExecutionException/ CompletionException, come combinare le fasi ( thenApply, thenAccept) e quali errori tipici evitare.

Come «concatenare» correttamente i passi asincroni in CompletableFuture con thenCompose e quando basta thenApply; come e perché collegare un pool di thread proprio tramite ExecutorService (invece di ForkJoinPool.commonPool()); come proteggere le catene dall’«attesa infinita» con orTimeout e completeOnTimeout. Alla fine — un esempio pratico con un Executor personalizzato, thenCompose e un timeout, nonché errori tipici e le loro soluzioni.