Работал ли ты с параллельными стримами и когда они имеют смысл?

Параллельные стримы — это не универсальное решение для ускорения кода.

Определение

Parallel Stream — это Stream, который обрабатывает элементы коллекции параллельно, используя ForkJoinPool.commonPool.

Создание:

list.parallelStream()
    .map(x -> x * x)
    .sum();

Когда параллельные стримы имеют смысл

Перед применением важно оценить несколько факторов.

1. Тип задачи

   • CPU-bound операции

   • Тяжёлые вычисления

   • Нет блокировок

2. Размер данных

   • Тысячи и миллионы элементов

   • Мелкие коллекции не дают выигрыша

3. Независимость операций

   • Нет изменения общего состояния

   • Нет синхронизации

Когда они вредны

1. I/O операции

   • Работа с БД

   • HTTP-запросы

   • Файлы

2. Синхронизация

   • synchronized

   • lock

   • Общие коллекции

3. Ограничения пула

   • Используется ForkJoinPool.commonPool

   • Можно повлиять на другие части приложения

Проблемы и подводные камни

1. Непредсказуемая производительность

2. Сложность отладки

3. Побочные эффекты

   • forEach с изменением внешних переменных

Плохой пример:

list.parallelStream()
    .forEach(x -> sharedList.add(x)); // race condition

Вывод

Параллельные стримы полезны для вычислений без побочных эффектов и с большим объёмом данных. Во всех остальных случаях лучше использовать явные ExecutorService или обычные стримы.