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

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

我们知道，Java中的Stream<T>处理的是对象，但如果你处理的是大量的数字（int、long、double），就需要注意“装箱与拆箱（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>没有的终端操作：

🧮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();// ✅ 无副作用

✅ 总结小贴士