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

Java Stream 是处理集合数据的高效方式，它不修改原始数据，而是通过声明式语法构建“流水线”，把一连串操作（如过滤、映射、聚合）组织成可读性强、支持并行的处理流程。

Stream 的核心特点：惰性求值与不可重用

Stream 不是数据容器，而是一次性的计算管道。创建后不会立即执行任何中间操作（如 filter、map），只有遇到终止操作（如 collect、count、forEach）时，整条流水线才真正运行。一旦调用过终止操作，该 Stream 就关闭，再次使用会抛出 IllegalStateException。

• 正确写法：一次构建，一次消费
  List names = list.stream().filter(s -> s.length() > 3).map(String::toUpperCase).collect(Collectors.toList());
• 错误写法：重复调用终止操作
  Stream s = list.stream();
  s.collect(...);
  s.count(); // 抛异常

常用中间操作：链式组装逻辑

中间操作返回新的 Stream，支持无限链式调用，构成清晰的数据转换路径。

Gradle 9.8.0

下载

• filter：按条件保留元素，例如 stream.filter(x -> x % 2 == 0)
• map：一对一转换，例如 stream.map(Person::getName)
• flatMap：一对多展开，常用于处理嵌套结构，例如将 List> 扁平为 Stream
• 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