Future — дескриптор результата с единственным способом получить значение: блокирующий get(). CompletableFuture позволяет описать цепочку продолжений (thenApply, thenCompose, thenCombine, allOf), которая выполнится по готовности, — без блокировки потока.
А ещё Async-стадии без своего executor идут в общий commonPool
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Ограничения Future: результат забирают блокирующим get(). Чтобы объединить два асинхронных вызова, нужно заблокировать поток на каждом. Колбэков нет, комбинировать нельзя.
CompletableFuture реализует Future и CompletionStage:
sottoCompletableFuture<User> user = supplyAsync(() -> loadUser(id), io);
CompletableFuture<List<Order>> orders = supplyAsync(() -> loadOrders(id), io);
user.thenCombine(orders, Profile::new)
.thenApply(this::render)
.exceptionally(e -> fallbackPage())
.thenAccept(this::send);thenApply — преобразовать значение;thenCompose — следующий шаг сам асинхронный (развернуть вложенный);thenCombine — объединить два независимых результата;allOf, anyOf — ждать группу.Ошибки. Исключение в стадии не летит сразу: future завершается с ошибкой, следующие then* пропускаются, пока не встретится exceptionally, handle или whenComplete. При join() исключение приходит в CompletionException, при get() — в ExecutionException; настоящая причина — в getCause().
Потоки. Продолжение без суффикса Async может выполниться в потоке, завершившем предыдущую стадию, или в вызывающем. Async-варианты без аргумента используют ForkJoinPool.commonPool() — блокирующие операции отдают в свой executor.
Один верный вариант. Подумайте, потом откройте ответ.
Ограничения Future, асинхронная композиция CompletableFuture, async-варианты с пулами и обработка ошибок.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.