База Hintsage

Программирование Java

Язык Java, JVM и экосистема серверной разработки.

Темы раздела

Выберите подраздел

Практика

Вопросы: Программирование Java

Разберите ошибку в объявлении Collector: почему параллельный сбор может повредить результат, несмотря на наличие combiner?

import java.util.*;
import java.util.stream.*;

Collector<Integer, List<Integer>, List<Integer>> bad = Collector.of(
    ArrayList::new,
    List::add,
    (left, right) -> { left.addAll(right); return left; },
    Collector.Characteristics.CONCURRENT
);

List<Integer> result = IntStream.range(0, 100_000)
    .parallel().unordered().boxed().collect(bad);

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

String result = IntStream.rangeClosed(1, 1000)
    .parallel()
    .boxed()
    .reduce(
        new StringBuilder(),
        (builder, value) -> builder.append(value).append(','),
        (left, right) -> left.append(right)
    )
    .toString();
Программирование JavaStream APIJava-разработчик серверных приложений

Показано 81100 из 403