Блог

У меня есть следующая функция:

 public Stream getStream(boolean isParallel) {

...
return someSteamFromHere;
}
  

Эта функция вернет параллельный поток, если значение «isParallel» равно true, в противном случае последовательный поток. Теперь я хочу собрать этот параллельный / последовательный поток. Должна ли вызывающая функция реализовывать эту логику:

 boolean isParallel = isParallel();
Stream stream = getStream(isParallel);
List list;
if (isParallel) {
   list = stream.parallel().collect(Collectors.toList());
} else {
   list = stream.collect(Collectors.toList());
}
  

Или я могу просто собирать поток независимо, и если он параллельный, он будет собираться параллельно, а если последовательный, он будет собираться в одном потоке?

параллелизм является свойством потока. Итак, если у вас есть параллельный поток, вызов этого не выполняется. .parallel() Он абсолютно ничего не делает.

Обратите внимание, что сбор параллельного потока подразумевает, что любая концепция «порядка» прямо из окна.

Ваш код может быть просто List list = stream.collect(Collectors.toList()); .

Обратите внимание, что, как правило, если параллелизм вообще имеет значение, сбор его в список кажется … странным. Какие бы преимущества в производительности, которые, по вашему мнению, вы получаете от параллельной обработки, в значительной степени уничтожаются, когда вы это делаете.

Почему вы передаете логическое значение функции, если используете его после возврата функции? Либо функция получает логическое значение и использует его, либо не получает его, и тест остается снаружи, как вы написали. Кстати, функции с логическими параметрами считаются запахом кода, поскольку они явно выполняют несколько функций. Посмотрите здесь.