272. Java Stream API - 使用数字专用流,避免装箱开销
2026/8/19 5:59:22 网站建设 项目流程

文章目录

  • 272. Java Stream API - 使用数字专用流,避免装箱开销
      • 🚫 问题:普通 `Stream` 会引发装箱性能问题
      • ✅ 解决方案:使用数字专用流
      • 📊 IntStream 示例:终端操作更丰富
      • 🧮 `summaryStatistics()` 示例
    • ✅ 最佳实践:使用 Stream 的注意事项
      • ⚠️ 一、不要复用 Stream 对象
      • ⚠️ 二、不要把 `Stream` 存成字段或变量长期保留
      • ⚠️ 三、避免对流外部变量产生副作用
    • ✅ 总结小贴士

272. Java Stream API - 使用数字专用流,避免装箱开销

我们知道,Java中的Stream<T>处理的是对象,但如果你处理的是大量的数字(intlongdouble),就需要注意“装箱与拆箱(boxing/unboxing)”的问题。

🚫 问题:普通Stream会引发装箱性能问题

Stream<Integer>numbers=List.of(1,2,3,4).stream();// 每个 int 都是 Integer 对象intsum=numbers.reduce(0,Integer::sum);// 多次装箱与拆箱,性能不佳

✅ 解决方案:使用数字专用流

Java提供了三个专用数字流接口来避免装箱开销:

  • IntStream:处理int值流
  • LongStream:处理long值流
  • DoubleStream:处理double值流

它们使用的是原始类型(primitive types,不会自动装箱,性能更高。


📊 IntStream 示例:终端操作更丰富

importjava.util.stream.IntStream;publicclassStatExample{publicstaticvoidmain(String[]args){IntStreamstream=IntStream.of(10,20,30,40,50);intsum=stream.sum();// 🚀 无装箱,高效计算System.out.println("Sum: "+sum);// 输出:Sum: 150}}

数字流接口提供了一些Stream<T>没有的终端操作:

方法名描述
sum()计算总和
min(),max()查找最小值和最大值
average()计算平均值(返回OptionalDouble
summaryStatistics()返回一个统计对象:总数、最小、最大、平均、总和

🧮summaryStatistics()示例

IntSummaryStatisticsstats=IntStream.of(10,20,30,40).summaryStatistics();System.out.println("Count: "+stats.getCount());System.out.println("Sum: "+stats.getSum());System.out.println("Average: "+stats.getAverage());System.out.println("Min: "+stats.getMin());System.out.println("Max: "+stats.getMax());

输出:

Count:4Sum:100Average:25.0Min:10Max:40

🎯 只需遍历一次数据流,五个指标一次到位!


✅ 最佳实践:使用 Stream 的注意事项

使用 Stream 时,以下行为要避免或注意,以确保安全性、可读性和性能。


⚠️ 一、不要复用 Stream 对象

错误示例:

Stream<String>stream=List.of("A","B","C").stream();varupper=stream.map(String::toUpperCase);varlist=stream.toList();// ❌ 第二次使用同一个 stream,会抛异常!

正确示例:

List<String>data=List.of("A","B","C");varupper=data.stream().map(String::toUpperCase).toList();varlower=data.stream().map(String::toLowerCase).toList();// ✅ 每次新建 stream

📌流只能使用一次,操作完就“关闭”了。


⚠️ 二、不要把Stream存成字段或变量长期保留

为什么?
Stream 是连接到数据源的“流水线”,并不存储数据。如果保存到字段中,容易:

  • 被重复使用引发错误
  • 引入副作用
  • 增加代码难以追踪的数据流动问题

✅ 最佳实践:流应就地创建、就地消费!

// ✅ 好做法List<Integer>result=List.of(1,2,3).stream().map(i->i*2).filter(i->i>3).toList();

⚠️ 三、避免对流外部变量产生副作用

int[]total={0};List.of(1,2,3).stream().forEach(i->total[0]+=i);// ❌ 修改外部变量,副作用!System.out.println(total[0]);

这段代码虽然能运行,但它:

  • 破坏了函数式编程的纯粹性
  • 在并行流中(parallel stream)可能导致竞态条件(race condition)

✅ 推荐写法:

intsum=List.of(1,2,3).stream().mapToInt(Integer::intValue).sum();// ✅ 无副作用

✅ 总结小贴士

规则原因
✔ 使用 IntStream、LongStream、DoubleStream避免装箱,提高数字处理性能
✔ 每次新建 stream,不要重复使用同一个Stream 一次性消费,不能重复使用
✔ 不要把 stream 存成字段或变量长期保留增加代码复杂性,并可能导致使用错误
✔ 避免修改外部变量(无副作用)保持函数式风格,保证线程安全
✔ 中间操作返回新 stream,不会立刻执行执行在终端操作触发时才发生

需要专业的网站建设服务?

联系我们获取免费的网站建设咨询和方案报价,让我们帮助您实现业务目标

立即咨询