Java Stream API要求明确区分中间操作(如filter、map)与终止操作(如collect、forEach),因Stream惰性求值,仅当中间操作后接终止操作才会执行;collect需配合Collectors使用,forEach与peek用途不同,findFirst返回Optional须判空,且同一Stream不可重复使用。

Java 的 Stream API 不是“多学几个方法就行”,而是得先分清哪些操作是中间操作、哪些是终止操作,否则链式调用会出错或不执行。
哪些方法必须成对出现:中间操作 vs 终止操作
Stream 是惰性求值的——只写 filter()、map()、sorted() 这类中间操作,什么都不会发生。必须接一个终止操作(如 collect()、forEach()、count())才会真正触发计算。
-
常见中间操作:
filter()、map()、flatMap()、sorted()、distinct()、limit()、skip() -
常见终止操作:
collect()、forEach()、reduce()、count()、findFirst()、anyMatch()、allMatch() - 错误示例:
list.stream().filter(x -> x > 0).map(String::valueOf); // 没有终止操作 → 白写
collect() 怎么选下游收集器才不踩坑
collect() 是最常用也最容易写错的终止操作。它不直接返回 List 或 Map,而是依赖 Collectors 工具类提供具体行为。
- 要转
List:用Collectors.toList(),不是new ArrayList() - 要转
Set:用Collectors.toSet(),注意无序且去重 - 要转
Map:必须指定 key 和 value,且 key 不能重复,否则抛IllegalStateException - 安全写法(避免 key 冲突):
Map<Integer, String> map = list.stream() .collect(Collectors.toMap( Person::getId, Person::getName, (v1, v2) -> v1 // 冲突时保留第一个 ));
forEach() 和 peek() 看似相似,用途完全不同
forEach() 是终止操作,用于消费流元素;peek() 是中间操作,仅用于调试或副作用,但不能替代 forEach()。
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式,或要求按照代码注释规范处理 Java 文件时,使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则,并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括:补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
立即学习“Java免费学习笔记(深入)”;
- 想遍历并打印日志(调试)→ 用
peek(),可继续链式调用list.stream() .filter(x -> x > 0) .peek(System.out::println) // ✅ 中间操作,不影响后续 .map(x -> x * 2) .collect(Collectors.toList()); - 只想遍历做 I/O 或修改外部状态 → 用
forEach(),但它是终止操作,后面不能再接其他 Stream 方法list.stream().forEach(System.out::println); // ❌ 后面加 .map() 编译失败
- 并发流中
forEach()不保证顺序,要顺序遍历请用forEachOrdered()
Optional 和 findFirst() 配合时别忘了判空
findFirst() 返回的是 Optional<t></t>,不是原始类型。直接调 .get() 是高危操作,一旦流为空就抛 NoSuchElementException。
- 安全做法优先用
orElse()、orElseGet()或ifPresent() - 反模式:
String first = list.stream().filter(s -> s.startsWith("a")).findFirst().get(); // 可能崩溃 - 推荐写法:
String first = list.stream() .filter(s -> s.startsWith("a")) .map(String::toUpperCase) .findFirst() .orElse("default"); - 如果后续逻辑复杂,用
ifPresent()更清晰:optional.ifPresent(value -> doSomething(value));
Stream 的核心约束很明确:中间操作可叠加,终止操作只能有一个,且不可重复使用同一 Stream 实例。很多人卡在“为什么没输出”“为什么报错说 stream 已关闭”,往往就是漏了终止操作,或在同一个 Stream 上多次调用了 collect() 或 forEach()。

















