Каким образом Stream в параллельном режиме использует потоки для обработки данных?

В Java Stream API параллельный режим (parallelStream()) использует пул потоков из ForkJoinPool.commonPool() для распределения обработки элементов коллекции между несколькими потоками.

Когда вы вызываете parallelStream(), поток данных разбивается на несколько частей (сплайттеры), которые обрабатываются параллельно разными потоками. Затем результаты объединяются (редуцируются) в итоговый результат.

Это позволяет ускорить обработку больших объемов данных, эффективно используя многоядерные процессоры. Однако стоит учитывать накладные расходы на создание и синхронизацию потоков, поэтому для небольших наборов данных параллельность может быть неэффективна.

Пример:

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6);
int sum = numbers.parallelStream()
                 .mapToInt(Integer::intValue)
                 .sum();

Здесь сумма считается параллельно, разбивая список на части и обрабатывая их в разных потоках.