Java Lambda 复用 Stream

Question

我想尝试 lambda 的一些功能，并想编写一个 ArrayList 过滤器，并使用 IntStream 的方法来计算 ArrayList 中数字的平均值和最大值

我的第一个想法是过滤 ArrayList，保存流，然后使用方法来计算:

ArrayList<Integer> arr = new ArrayList<>();
arr.add(5);
arr.add(7);
arr.add(11);

IntStream s = arr.stream().filter(i -> i < 10).mapToInt(i -> (int)i);
int maxBelowTen = s.max().getAsInt();
double avgBelowTen = s.average().getAsDouble();
System.out.println("Maximum below ten: " + maxBelowTen);
System.out.println("Average below ten: " + avgBelowTen);

但是，这会抛出 java.lang.IllegalStateException:流已被操作或关闭

有了这些信息，我当然可以通过打开两个流并过滤两次来使其发挥作用

int maxBelowTen = arr.stream().filter(i -> i < 10).mapToInt(i -> (int) i).max().getAsInt();
double avgBelowTen = arr.stream().filter(i -> i < 10).mapToInt(i -> (int) i).average().getAsDouble();

但我现在的问题是关于性能的。如果我必须过滤和映射流两次，那不是很慢吗？为什么我不能在一个流上操作多次，我不明白他们为什么这样实现。难道不可能在操作后保持流打开吗，因为每个运算符方法都会返回一个新流或单个值。

这是什么原因，还是我用错了？

Answer 1

如果您采用良好的旧方法，即使用循环，则可以使用单个循环计算最大元素和平均值。所以你只需要在这里做同样的事情。幸运的是，Stream API 可以为您做到这一点:

IntStream s = arr.stream().mapToInt(i -> Integer::intValue).filter(i < 10);
IntSummaryStatistics stats = s.summaryStatistics();

double average = stats.getAverage();
int max = stats.getMax();

阅读 IntSummaryStatistics 的 javadoc 应该可以帮助您了解如何自己实现这样的操作。