Привет, у меня вопрос о parallelism при использовании плоской карты Рассмотрим следующий пример
IntStream.of(-1, 1).parallel().flatMap(i->IntStream.range(0,1000).parallel()).forEach(System.out::println);
Неважно, устанавливаю ли я внутренний флажок? Результаты выглядят очень схожими, если я оставлю это или нет. Также почему код (ReferencePipeline) упорядочивает отображение? Я запутался в строке:
result.sequential().forEach(downstream);
В текущем JDK (jdk1.8.0_25) ответ отрицательный, не имеет значения, вы устанавливаете внутренний флаг в параллель, потому что даже вы его установили, .flatMap() вернула поток в последовательный здесь:
result.sequential().forEach(downstream);
( "result" - это внутренний поток, а последовательный() метод doc говорит: Возвращает эквивалентный поток, который является последовательным. Может вернуться сама, потому что поток уже был последовательным или потому, что состояние базового потока было изменено, чтобы быть последовательным.)
В большинстве случаев может быть без усилий, чтобы внутренний поток был параллельным; если внешний поток имеет по крайней мере то же количество элементов, что и количество потоков, которые могут выполняться параллельно (ForkJoinPool.commonPool(). getParallelism() = 3 на моем компьютере).