⌨️ Параллельные и последовательные потоки (Stream)

Последовательные потоки (Sequential Streams)

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

✔️ Используют основной поток программы (main thread) для выполнения операций.

✔️ Метод stream() создаёт последовательный поток.

Пример последовательного потока:

List<String> list = List.of("Hello ", "w", "o", "r", "l", "d!");
list.stream().forEach(System.out::print);
// Hello world!

Параллельные потоки (Parallel Streams)

✔️ Обрабатывают элементы параллельно, распределяя их между несколькими потоками (threads), что позволяет использовать многопоточность.

✔️ Используют ForkJoinPool для распределения задач между потоками.

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

✔️ Параллельный поток можно создать, вызвав метод parallelStream() или применив метод parallel() к уже существующему потоку.

Пример параллельного потока:

List<String> list = List.of("Hello ", "w", "o", "r", "l", "d!");
list.parallelStream().forEach(System.out::print);
// rlHello d!wo

#java #Stream #parallelStream

❓ Как избежать проблем с Parallel Stream?

Использование parallelStream() может замедлить программу, если не учитывать его особенности.

➡️ Проблемы:

🟢 Не стоит использовать с маленькими коллекциями – накладные расходы на потоки выше, чем выгода.
🟢 Будьте осторожны с изменяемыми переменными в forEach().

❌ Ошибка: некорректное изменение общей переменной

int[] sum = {0};
list.parallelStream().forEach(i -> sum[0] += i); // Потенциальная ошибка!

📌 Решение: использовать reduce()

int sum = list.parallelStream().reduce(0, Integer::sum);

💡 Совет: parallelStream() эффективен, если объём данных большой и нет конкурентного доступа.

#java #parallelstream #performance