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

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

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

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

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

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

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

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

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

Терминальная операция anyMatch передаёт элементы предикату до тех пор, пока предикат не вернёт true. После этого операция фиксирует итог true и распространяет сигнал короткого замыкания по конвейеру. Источник и промежуточные операции прекращают выдавать новые элементы, когда это становится возможным.

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

boolean exists = numbers.stream()
    .map(this::loadValue)
    .anyMatch(value -> value > 100);

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

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

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

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

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

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

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

1. Прекращает ли anyMatch выполнение предиката абсолютно сразу после первого true?

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

2. Гарантирует ли anyMatch, какой именно подходящий элемент будет найден?

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

3. Можно ли использовать побочный эффект предиката для подсчёта фактически проверенных элементов?

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