Java Stream操作中遇到匹配条件的元素时能否提前终止流？

问题解答 #

1. 完全可以用单次连续的流操作完成需求，同时也能实现遇到null元素立即终止流的短路效果。
2. 你原来的写法会遍历两次列表，在列表数据量大的时候性能开销更高，改用单次流+短路逻辑的实现如下：

import java.util.concurrent.atomic.AtomicInteger;

// 核心逻辑
AtomicInteger sumHolder = new AtomicInteger(0);
boolean existNull = intList.stream()
        .anyMatch(item -> {
            if (item == null) {
                // 遇到null直接返回true，触发anyMatch短路终止
                return true;
            }
            sumHolder.addAndGet(item);
            return false;
        });
Integer result = existNull ? null : sumHolder.get();

逻辑说明

• anyMatch本身就是Java Stream内置的短路终止操作，只要遇到第一个匹配（返回true）的元素，就会立刻停止后续元素的处理，不会全量遍历列表，性能表现更好。
• 这里用AtomicInteger承载累加结果，是因为Lambda表达式内部只能引用外部的final或者effectively final变量，普通int变量无法在Lambda内部修改，原子类既符合语法要求，也能保证单线程场景下的累加正确性。

如果不需要短路效果，仅要求单次流遍历，也可以用自定义收集器实现：

Integer result = intList.stream()
        .collect(
            () -> new AtomicReference<>(0),
            (ref, item) -> {
                if (ref.get() != null) {
                    ref.set(item == null ? null : ref.get() + item);
                }
            },
            (ref1, ref2) -> {
                if (ref1.get() != null && ref2.get() != null) {
                    ref1.set(ref1.get() + ref2.get());
                } else {
                    ref1.set(null);
                }
            }
        ).get();

该实现没有短路效果，哪怕遇到null仍会遍历完全部元素，性能低于第一种短路写法。

内容的提问来源于stack exchange，提问作者maybesomename