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