Что хотят услышать интервьюеры:

parallelStream() позволяет обработать элементы коллекции параллельно, используя общий пул потоков Java. Это удобно для задач, где операции над элементами независимы и достаточно тяжелые, чтобы окупить накладные расходы на распараллеливание. При этом важно помнить про безопасность потоков, порядок выполнения и то, что не любую задачу выгодно переводить в parallel.

Определение:

parallelStream() — это способ получить поток, который Java может выполнять не в одном, а в нескольких потоках одновременно. Внутри обычно используется ForkJoinPool.commonPool, а коллекция разбивается на части для параллельной обработки. Такой подход полезен для CPU-bound операций, когда элементы можно обрабатывать независимо друг от друга.

Пример использования:

import java.util.List;
import java.util.stream.Collectors;

public class ParallelStreamExample {
    public static void main(String[] args) {
        List<Integer> numbers = List.of(1, 2, 3, 4, 5, 6);

        List<Integer> result = numbers.parallelStream()
                .map(n -> n * n)
                .collect(Collectors.toList());

        System.out.println(result);
    }
}

В этом примере каждый элемент списка возводится в квадрат параллельно.

Пояснение кода:

numbers.parallelStream() создает параллельный поток из списка.
map(n -> n * n) применяет преобразование к каждому элементу независимо от других.
Java может распределить обработку элементов между несколькими потоками из общего пула.
collect(Collectors.toList()) собирает результат обратно в список.

Код подходит, потому что операция n * n не зависит от порядка и от соседних элементов. Если бы внутри map изменялось общее состояние, это могло бы привести к ошибкам.

Ключевые моменты:

parallelStream() полезен для независимых и относительно тяжелых операций.
Распараллеливание не всегда ускоряет выполнение: для маленьких коллекций может быть медленнее обычного stream().
Операции в потоке должны быть thread-safe и желательно без побочных эффектов.
Порядок выполнения элементов может отличаться от последовательного потока.
Результат можно собирать стандартными терминальными операциями, например collect, forEach, reduce.

Как реализуется параллельная обработка данных в Java с помощью метода parallelStream?