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

В Java метод parallelStream() позволяет выполнять операции над коллекциями параллельно, используя несколько потоков из общего пула ForkJoinPool. Это ускоряет обработку больших объемов данных за счет распараллеливания задач.

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

import java.util.Arrays;
import java.util.List;

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

        int sumOfSquares = numbers.parallelStream()
            .mapToInt(n -> n * n)
            .sum();

        System.out.println("Сумма квадратов: " + sumOfSquares);
    }
}

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