java Reduce的三种重载

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)

基本上就这些。选哪个取决于是否允许空流、是否需要恒等值语义、以及是否走并行流。