Fork/Join — рекурсивное деление задачи на подзадачи (fork) с последующим объединением результатов (join). Work stealing: у каждого рабочего потока своя двусторонняя очередь, а освободившийся поток крадёт задачи с хвоста чужой очереди — нагрузка балансируется сама.
А ещё Порог деления: слишком мелкие задачи съедают выигрыш накладными расходами
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Модель. Задача проверяет размер: мала — решает напрямую, иначе делится на части, одну отправляет fork(), другую решает сама, затем join() собирает результат.
sottoclass Sum extends RecursiveTask<Long> {
protected Long compute() {
if (hi - lo < 10_000) return directSum();
Sum left = new Sum(arr, lo, mid);
left.fork();
long right = new Sum(arr, mid, hi).compute();
return left.join() + right;
}
}Work stealing. Каждый поток ForkJoinPool кладёт свои подзадачи в собственную деку и берёт их с головы (LIFO — горячие данные в кэше). Свободный поток крадёт у других с хвоста — там самые крупные, ещё не разделённые задачи. Нет единой очереди, за которую бьются все.
Ограничения:
ForkJoinPool.commonPool() общий на всю JVM — его используют parallel stream и CompletableFuture без своего executor.Состояние на поток и утечки в пулах, InheritableThreadLocal, work-stealing в ForkJoinPool и общий пул parallel streams.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.