ExecutorService, размеры пулов, Future и CompletableFuture, ThreadLocal и Fork/Join.
sottothenApply, thenCompose, allOf, exceptionally, orTimeout.CompletableFuture уходит в общий ForkJoinPool.ThreadLocal в пуле надо очищать.Практика. Параллельно опросить 5 внешних сервисов через CompletableFuture с общим таймаутом и частичными результатами.
Пул переиспользует потоки и ограничивает их число: создание потока дорого, а неограниченный рост убивает приложение.
Поток в пуле переиспользуется: значение ThreadLocal, не очищенное после задачи, протекает в следующую задачу (чужой пользователь, транзакция) и удерживает память. Правило: try {…
Fork/Join — рекурсивное деление задачи на подзадачи (fork) с последующим объединением результатов (join). Work stealing: у каждого рабочего потока своя двусторонняя очередь, а…
Future — ссылка на результат, который появится позже: можно проверить готовность, дождаться значения или отменить задачу.
Future — дескриптор результата с единственным способом получить значение: блокирующий get(). CompletableFuture позволяет описать цепочку продолжений (thenApply, thenCompose…
Async-стадии без Executor выполняются в ForkJoinPool.commonPool — он общий на всю JVM и размером примерно число ядер − 1. Блокирующие вызовы (HTTP, БД, get чужого future) занимают…
Зачем пул, параметры ThreadPoolExecutor, ловушки фабрик Executors, выбор размера и корректное завершение.
Ограничения Future, асинхронная композиция CompletableFuture, async-варианты с пулами и обработка ошибок.
Состояние на поток и утечки в пулах, InheritableThreadLocal, work-stealing в ForkJoinPool и общий пул parallel streams.
На живом собеседовании sotto слышит вопрос интервьюера и показывает короткий ответ и план. Оставьте контакт — пришлём доступ и промокод.