Java流计算均值技巧分享

Java 中的 `Collectors.averagingInt()` 提供了一种简洁、高效且安全的单次遍历方式来计算整型流的平均值，自动使用 long 累加防止 int 溢出，空流时返回 Double.NaN 以明确提示无数据，相比手动两次遍历求和再除以数量更优；它要求流元素能通过 `mapToInt()` 映射为 int，适用于 Integer 流、对象字段提取等场景，但需注意空指针风险与装箱开销，并建议在生产环境中主动校验 NaN 以保障健壮性——是 Java 流式统计中兼顾性能、安全与可读性的首选方案。

在 Java 中，Collectors.averagingInt() 可以直接对 Stream 或其他支持映射为 int 的流，在一次遍历中算出平均值（返回 double），无需手动求和再除以数量，简洁且高效。

确保数据源能映射为 int 类型

该收集器只接受 ToIntFunction，所以原始流元素必须能通过 mapToInt() 转成 int。常见适用场景：

• 流本身是 Stream：直接用 mapToInt(Integer::intValue)
• 流是自定义对象：用 mapToInt(obj -> obj.getScore()) 提取整型字段
• 避免使用 mapToInt(String::length) 等可能隐含空指针或装箱开销的操作，提前校验

调用方式要写在 collect() 内部

不能单独调用 averagingInt()，它必须作为 collect() 的参数。典型写法：

double avg = list.stream().mapToInt(Integer::intValue).collect(Collectors.averagingInt(i -> i));

更常见的简化写法（因 i -> i 是恒等函数）：

double avg = list.stream().mapToInt(Integer::intValue).collect(Collectors.averagingInt(i -> i));
或者直接：

double avg = list.stream().mapToInt(Integer::intValue).collect(Collectors.averagingInt(Function.identity()));

注意空流会返回 Double.NaN

如果输入流为空，averagingInt() 返回 Double.NaN，不是 0 或异常。生产环境建议检查：

• 用 Double.isNaN(avg) 判断是否无数据
• 可配合 Optional 封装：先 stream.findFirst() 判空，再计算
• 若业务要求空时返回 0，可写成 Double.isNaN(avg) ? 0.0 : avg

性能与替代方案对比

相比手动 reduce 求和再除长度，averagingInt() 在底层做了单次遍历 + 精度优化，更适合多数场景：

• 它内部使用 long 累加和，避免 int 溢出（但极端大数据量仍需留意）
• 比先 mapToInt().sum() 再除 count() 更安全——后者会触发两次遍历，对非集合流（如 I/O 流、生成流）不可行
• 若还需标准差、最大最小值等，考虑用 Collectors.summarizingInt() 一次性获取全部统计值

今天关于《Java流计算均值技巧分享》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！