Создает ли на каждый Parallel Stream свой пул потоков

Параллельные потоки в Java: общий пул ForkJoinPool

Короткий ответ: Нет, каждый Parallel Stream не создаёт свой пул потоков. Все параллельные потоки по умолчанию используют общий ForkJoinPool.commonPool() — это глобальный пул, который переиспользуется всеми потоками в приложении.

Как работает Parallel Stream

Когда вы создаёте параллельный поток:

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8);
int sum = numbers.parallelStream()
    .map(n -> n * 2)
    .reduce(0, Integer::sum);

Это не создаёт новый пул потоков каждый раз. Вместо этого используется глобальный ForkJoinPool:

// Примерно то, что происходит под капотом:
ForkJoinPool commonPool = ForkJoinPool.commonPool();
// Размер: Runtime.getRuntime().availableProcessors()

Размер общего пула

Пул потоков имеет фиксированный размер, равный количеству процессоров:

int poolSize = Runtime.getRuntime().availableProcessors();
// На 8-ядерном компьютере: 8 потоков

int parallelism = ForkJoinPool.commonPool().getParallelism();
System.out.println("Parallelism level: " + parallelism);

Возможность создания собственного пула

Если вам нужен отдельный пул, вы можете создать его явно:

// Создаём собственный ForkJoinPool
ForkJoinPool customPool = new ForkJoinPool(4); // 4 потока

// Используем в Stream
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8);
Integer result = customPool.invoke(
    numbers.parallelStream()
        .map(n -> n * 2)
        .collect(Collectors.toList())
);

Проблемы с общим пулом

Потенциальная блокировка:

// Опасно: если блокирующая операция используется в общем пуле
numbers.parallelStream()
    .forEach(n -> {
        // Блокирующая операция здесь замораживает общий пул
        blockingIO();
    });

Решение — использовать собственный пул для блокирующих операций.

Практические рекомендации

1. Используйте parallelStream() только для CPU-bound операций без блокировки
2. Для I/O-bound задач используйте собственный ForkJoinPool или ExecutorService
3. Избегайте вложенных параллельных потоков — это неэффективно
4. Профилируйте перед использованием параллелизма

Итог

Все параллельные потоки в Java работают через один общий ForkJoinPool, что экономит ресурсы, но требует внимательности при использовании блокирующих операций.