Java Stream.reduce()有三种重载:1.无初始值型返回Optional,要求流非空;2.有初始值型以identity为起点和空流默认值,满足恒等律;3.并行型含accumulator与combiner,支持分段计算合并。
Java Stream.reduce() 有三种常用重载形式,分别适用于不同场景:无初始值、有初始值、带组合器的并行处理。
1. 无初始值的 reduce(Optional reduce(BinaryOperator accumulator))
只接收一个累加器函数,要求流非空,否则返回空 Optional。适合明确知道流不为空、且类型可自然累积的情况,比如求最大值、最小值或字符串拼接。
- 返回 Optional
,需调用 orElse()或orElseThrow()解包 - 内部用第一个元素作起点,后续逐个累积
- 示例:
list.stream().reduce(Integer::max).orElse(0)
2. 有初始值的 reduce(T reduce(T identity, BinaryOperator accumulator))
提供一个恒等值(identity),作为累加起点和空流
时的默认结果。该值必须满足:对任意 t,accumulator.apply(identity, t) == t。常见如 0(加法)、1(乘法)、""(字符串连接)。
- 返回确定类型 T,无需判空
- 即使流为空也返回 identity
- 示例:
stream.reduce(0, (a, b) -> a + b)等价于stream.mapToInt(Integer::intValue).sum()
3. 并行友好的 reduce(U reduce(U identity, BiFunction accumulator, BinaryOperator combiner))
支持并行流分段计算后合并,需要三个参数:初始值、累加器(局部累积)、组合器(合并子结果)。常用于自定义对象聚合或需要中间转换的场景。
- accumulator 处理单个元素:
(partialResult, element) -> newResult - combiner 合并两个局部结果:
(result1, result2) -> merged - 示例:统计字符串总长度(并行安全)
stream.reduce(0, (len, s) -> len + s.length(), Integer::sum)
基本上就这些。选哪个取决于是否允许空流、是否需要恒等值语义、以及是否走并行流。








