Лекції

Розбираємо запуск і композицію асинхронних обчислень за допомогою CompletableFuture: як стартувати завдання через supplyAsync і runAsync, чим відрізняються обробники thenApply, thenAccept, thenRun, і коли обирати їх асинхронні версії thenApplyAsync/ thenAcceptAsync/ thenRunAsync. Поговоримо про потоки виконання ( ForkJoinPool або ваш Executor), типи результатів ( CompletableFuture<T>, CompletableFuture<Void>) і типові помилки: блокувальні виклики get()/ join(), необроблені помилки без exceptionally/ handle/ whenComplete, а також спроба використати результат усередині thenRun.

Як паралелити задачі й об’єднувати результати за допомогою CompletableFuture: об’єднання двох результатів через thenCombine/ thenCombineAsync, очікування набору задач через allOf, реакція на найшвидшу відповідь через anyOf. Розберемо сигнатури, практичні приклади з supplyAsync, неблокувальну обробку ( thenAccept, thenRun), а також нюанси помилок і їхню обробку ( exceptionally, handle, whenComplete). Наприкінці — компактна таблиця порівняння методів.

Як безпечно перехоплювати й обробляти винятки в ланцюжках CompletableFuture: розбираємо ролі exceptionally (резервне значення у разі помилки), handle (універсальний обробник успіху/помилки) і whenComplete (побічні дії без зміни результату). Обговоримо, чому прямий виклик get()/ join() загортає причини в ExecutionException/ CompletionException, як комбінувати етапи ( thenApply, thenAccept) і яких типових помилок уникати.

Як правильно «склеювати» асинхронні кроки в CompletableFuture за допомогою thenCompose і коли достатньо використати thenApply; як і навіщо підключати власний пул потоків через ExecutorService (замість ForkJoinPool.commonPool()); як убезпечити ланцюжки від «вічного очікування» за допомогою orTimeout і completeOnTimeout. Наприкінці — практичний приклад із власним Executor, thenCompose і тайм-аутом, а також типові помилки та способи їх розв’язання.