Краткий ответ

Промежуточные операции Stream API ленивы: они не проходят по элементам в момент вызова, а только формируют описание конвейера обработки. Фактический обход источника начинается после вызова терминальной операции, например получения результата или выполнения действия.

Исторический контекст

Stream API отделяет описание обработки данных от самой обработки. Такой подход решает проблему громоздких внешних циклов, где программист вручную управляет обходом, промежуточными результатами и условиями остановки.

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

Постановка проблемы

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

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

Подробное решение

Вызов промежуточной операции возвращает новый Stream или изменённое описание конвейера, но не запускает обработку. Внутри конвейера сохраняется последовательность функций, заданных через функциональные интерфейсы: например, предикат для фильтрации или функция преобразования.

Терминальная операция запускает обход источника. Для каждого элемента выполняется цепочка операций, причём результат одной операции передаётся следующей; поэтому обычно не создаются отдельные коллекции после каждого шага.

Например:

import java.util.List;

var result = List.of(1, 2, 3, 4).stream()
    .filter(n -> {
        System.out.println("filter " + n);
        return n % 2 == 0;
    })
    .map(n -> n * 10)
    .limit(1)
    .toList();

До вызова toList() фильтр не выполняется. После его вызова обработка остановится после нахождения первого подходящего элемента: благодаря этому limit может сократить объём работы.

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

Побочные эффекты внутри промежуточных операций особенно опасны: их выполнение зависит от наличия терминальной операции, порядка обхода и выбранного режима обработки. Надёжнее передавать данные между операциями через их результаты, а не изменять внешнее состояние.

Ситуация из практики

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

Вариант с ленивым конвейером, фильтрацией, преобразованием и ограничением одним результатом выполняет операции по мере необходимости. Его преимущество — ранняя остановка и отсутствие лишних промежуточных объектов; недостаток — сложность отладки, если в функциях оставлены побочные эффекты.

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

Что кандидаты часто упускают

Запускает ли вызов промежуточной операции обработку элементов, если результат этой операции присвоен переменной?

Нет. Присваивание сохраняет объект потока, но не является терминальной операцией. Обработка начнётся только при последующем терминальном вызове.

Всегда ли ленивый конвейер обрабатывает каждый элемент целиком от начала до конца?

Нет. Для обычных последовательных операций обработка часто идёт поэлементно через весь конвейер. Если встречается короткозамыкающая терминальная или промежуточная операция, например ограничение количества результатов, поток может завершить работу раньше.

Может ли порядок размещения операций изменить стоимость обработки при одинаковом результате?

Да. Дешёвую фильтрацию обычно выгодно выполнять до дорогого преобразования, чтобы преобразование применялось к меньшему числу элементов. Однако состояние-зависимые операции, такие как сортировка, могут потребовать накопления элементов и ограничить преимущества ранней фильтрации или короткого замыкания.