Такой код выглядит асинхронным:
CompletableFuture<User> future =
CompletableFuture.supplyAsync(() -> userClient.loadUser(id));
Но без явного
Executor задача обычно попадёт в общий ForkJoinPool.commonPool().Если
loadUser() ждёт HTTP, базу данных или файловую систему, поток блокируется. Несколько медленных вызовов могут занять весь общий пул и затормозить совершенно несвязанные операции приложения.Лучше выделить отдельный пул для блокирующего I/O:
private static final ExecutorService IO_POOL =
Executors.newFixedThreadPool(32);
CompletableFuture<User> future =
CompletableFuture.supplyAsync(
() -> userClient.loadUser(id),
IO_POOL
);
И не забыть корректно его закрыть:
IO_POOL.shutdown();
Для цепочки тоже важно явно выбирать executor:
future.thenApplyAsync(
user -> enrichUser(user),
IO_POOL
);
Почему это полезно:
- медленный внешний сервис не блокирует общий пул;
- нагрузку можно ограничить размером executor;
- проще наблюдать очередь и время выполнения;
- разные типы задач не мешают друг другу.
CompletableFuture не делает блокирующий код неблокирующим. Он лишь переносит ожидание в другой поток.Асинхронность без контроля executor - это просто блокировка в менее заметном месте.
