синтаксис parralel stream до java 8 release

Question

До официального выпуска Java 8, когда он все еще находился в разработке, я правильно понимаю, что синтаксис получения потоков и параллельных потоков был несколько иным. Теперь у нас есть возможность либо поговорке:

stream().parallel() или parallelStream()

Я помню, как читал учебники до его выхода, когда было тонкое различие здесь - может кто-нибудь напомнить о том, что это было, как это было давало мне покоя!

Answer 1

Текущая реализация не имеет никакого значения: .stream() создает конвейер с parallel набором поля для false, то .parallel() просто устанавливает это поле истины и возвращает тот же объект. При использовании .parallelStream() он создает конвейер с полем parallel, установленным в конструктор true. Таким образом, обе версии одинаковы. Любые последующие вызовы .parallel() или .sequential() просто делают то же самое: измените флаг режима потока на true или false и верните тот же объект.

Ранняя реализация Stream API была иной. Here's Исходный код AbstractPipeline (родительский для всех Stream, IntStream, LongStream и DoubleStream реализациях) в лямбда-dev незадолго до того, как была изменена логика. Установка режима на parallel() сразу после создания потока из разделителя была относительно дешевой: он просто извлекает spliterator из исходного потока (depth == 0 ветвь в spliteratorSupplier()), а затем создает новый поток в верхней части этого разделителя, отбрасывая исходный поток (те раз не было close()/onClose(), поэтому было необязательно делегировать тесные обработчики).

Тем не менее, если ваш источник потока включен промежуточные этапы (например, рассмотреть Collections.nCopies реализации, которая включает в себя map шага), вещи были хуже: с помощью .stream().parallel() бы create a new spliterator с бедным людьми стратегией расщепления (которая включает в себя буферизацию). Таким образом, для такой коллекции с использованием .parallelStream() было фактически лучше, так как оно использовалось внутренне .parallel()до промежуточная операция. В настоящее время даже для nCopies() вы можете использовать как .stream().parallel(), так и .parallelStream() взаимозаменяемо.

Идет еще больше назад, вы may notice, что .parallelStream() было вызвано просто .parallel() изначально. Он был переименован в this changeset.