我想尝试 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();
但我现在的问题是关于性能的。如果我必须过滤和映射流两次,那不是很慢吗?为什么我不能在一个流上操作多次,我不明白他们为什么这样实现。 难道不可能在操作后保持流打开吗,因为每个运算符方法都会返回一个新流或单个值。
这是什么原因,还是我用错了?
最佳答案
如果您采用良好的旧方法,即使用循环,则可以使用单个循环计算最大元素和平均值。所以你只需要在这里做同样的事情。幸运的是,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 应该可以帮助您了解如何自己实现这样的操作。
关于Java Lambda 复用 Stream,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24372139/