Java for Beginner

Вертикальная vs горизонтальная обработка

Критическое заблуждение о Stream API — представление, что элементы обрабатываются "по слоям": сначала все проходят filter, затем все проходят map, затем все попадают в collect. Реальность — вертикальная обработка: каждый элемент проходит через весь конвейер до конца, прежде чем берётся следующий.

Это архитектурное решение, необходимое для short-circuit. Если бы мы сначала фильтровали все элементы, мы не могли бы остановиться после нахождения первого подходящего — нам нужно было бы видеть все элементы, чтобы начать следующую стадию.

Рассмотрим конвейер:

books.stream()
    .filter(b -> { 
        System.out.println("Filter: " + b.title()); 
        return b.year() > 1950; 
    })
    .map(b -> {
        System.out.println("Map: " + b.title());
        return b.title().toUpperCase();
    })
    .limit(2)
    .forEach(System.out::println);

При вертикальной обработке вывод будет чередоваться:

Filter: Book A (1900)     // Отсеян, Map не вызывается
Filter: Book B (1960)     // Прошёл
Map: Book B               // Преобразован
BOOK B                    // forEach
Filter: Book C (1970)     // Прошёл
Map: Book C               // Преобразован
BOOK C                    // forEach
// limit(2) достигнут, остановка

Если бы обработка была горизонтальной, мы увидели бы сначала все "Filter:", затем все "Map:", затем результат. Но тогда limit(2) не смог бы прервать выполнение после второго элемента — все фильтрации уже произошли бы.
Вертикальность имеет следствия для побочных эффектов. Если peek или map содержат логирование или модификацию внешнего состояния, порядок вызовов будет чередующимся, а не пакетным. Это затрудняет отладку, но обеспечивает корректность short-circuit семантики.

Ленивость и исключения

Ленивое выполнение влияет на обработку исключений. Если исключение возникает в лямбде промежуточной операции, оно будет брошено только при терминальной операции, что может затруднить трассировку:

Stream<Book> stream = books.stream()
    .map(b -> {
        if (b.year() < 0) throw new IllegalStateException("Invalid year: " + b.year());
        return b;
    });
// Исключение не брошено

stream.forEach(System.out::println);  // Исключение здесь, стектрейс указывает на forEach

Более того, если short-circuit операция останавливается до элемента с ошибкой, исключение никогда не возникнет:

books.stream()
    .map(b -> {
        if (b.year() < 0) throw new IllegalStateException("Invalid year");
        return b;
    })
    .findFirst();  // Если первая книга валидна, исключение для второй (с ошибкой) не бросится

Это делает потоки непредсказуемыми с точки зрения полноты валидации. Если необходима проверка всех элементов, short-circuit операции неприменимы — нужно использовать collect или forEach, требующие полного обхода.

#Java #для_новичков #beginner #stream_api #stream #short_circuit

👍4🔥1

132 views08:59