Лекции

Разбираем запуск и композицию асинхронных вычислений с помощью 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 и тайм-аутом, а также типичные ошибки и их решения.