Java Stream 是一次性惰性求值的计算管道,支持链式中间操作(filter/map/flatMap/sorted)和终止操作(collect/reduce/findFirst等),并行流需谨慎使用。

Java Stream 是处理集合数据的高效方式,它不修改原始数据,而是通过声明式语法构建“流水线”,把一连串操作(如过滤、映射、聚合)组织成可读性强、支持并行的处理流程。
Stream 的核心特点:惰性求值与不可重用
Stream 不是数据容器,而是一次性的计算管道。创建后不会立即执行任何中间操作(如 filter、map),只有遇到终止操作(如 collect、count、forEach)时,整条流水线才真正运行。一旦调用过终止操作,该 Stream 就关闭,再次使用会抛出 IllegalStateException。
- 正确写法:一次构建,一次消费
Listnames = list.stream().filter(s -> s.length() > 3).map(String::toUpperCase).collect(Collectors.toList()); - 错误写法:重复调用终止操作
Streams = list.stream();
s.collect(...);
s.count(); // 抛异常
常用中间操作:链式组装逻辑
中间操作返回新的 Stream,支持无限链式调用,构成清晰的数据转换路径。
- filter:按条件保留元素,例如 stream.filter(x -> x % 2 == 0)
- map:一对一转换,例如 stream.map(Person::getName)
-
flatMap:一对多展开,常用于处理嵌套结构,例如将 List
- >
- sorted:支持自然序或自定义比较器,注意它不是稳定排序(相等元素相对位置可能变)
关键终止操作:触发执行并产出结果
终止操作终结流水线,决定最终输出形式。
立即学习“Java免费学习笔记(深入)”;
- collect:最常用,配合 Collectors 工具类实现灵活归集,如转 List、Set、Map,或分组(groupingBy)、分区(partitioningBy)
- reduce:适用于累积计算,如求和、拼接字符串;注意提供初始值避免空流异常
- findFirst / findAny:返回 Optional,适合短路查找;findAny 在并行流中性能更优
- count / max / min / anyMatch / allMatch:语义明确的聚合判断
并行流:简单开启,但需谨慎使用
只需将 stream() 换成 parallelStream(),底层自动使用 ForkJoinPool 分治处理。但它不是银弹:
- 数据量小或操作轻量时,并行反而因线程开销更慢
- 操作必须是无状态、不干扰、可组合的(如不能在 map 中修改共享变量)
- 顺序敏感的操作(如 limit、findFirst)在并行下行为可能变化,应优先用 findAny










