随着Java8的发布,Java SE 8 中引入的最重要的变化之一是新的Stream API。其中,groupingBy 和 summingInt 这两个方法,是用来完成分组求和操作的。下面将从多个方面详细介绍它们的使用方法。
一、groupingBy的使用
groupingBy方法是用来对流中的元素进行分组操作的。它接收一个lambda表达式作为参数,用于对流中的元素进行分组。
public static <T,K> Collector<T,?,Map<K,List<T>>> groupingBy(Function<? super T,? extends K> classifier)
其中,classifier表示用来对流中的元素进行分类的lambda表达式。下面是一个示例代码:
List<Person> people = Arrays.asList(
new Person("Tom", 13),
new Person("Jerry", 16),
new Person("Peter", 17),
new Person("Mary", 13)
);
Map<Integer, List<Person>> result = people.stream()
.collect(Collectors.groupingBy(Person::getAge));
上述代码使用groupingBy方法,对people列表根据年龄进行分组。结果是一个Map,key是年龄,value是这个年龄的所有Person对象的List。
二、summingInt的使用
summingInt方法是用来计算分组求和操作的。它接收一个lambda表达式作为参数,用于计算流中的元素。
public static <T> Collector<T,?,Integer> summingInt(ToIntFunction<? super T> mapper)
其中,mapper表示用来计算流中元素的值,返回一个int值的lambda表达式。下面是一个示例代码:
Map<Integer, Integer> result = people.stream()
.collect(Collectors.groupingBy(Person::getAge, Collectors.summingInt(Person::getCount)));
上述代码在分组的基础上,使用summingInt方法对每组元素的count属性进行求和。结果是一个Map,key是年龄,value是这个年龄下所有Person对象的count属性之和。
三、多级分组求和
groupingBy方法可以进行多级分组操作,也就是先根据第一个分类器进行分组,再根据第二个分类器进行分组。这种情况下,需要传入两个分类器类型的参数。下面是一个示例代码:
Map<String, Map<Integer, Integer>> result = people.stream()
.collect(Collectors.groupingBy(Person::getName,
Collectors.groupingBy(Person::getAge, Collectors.summingInt(Person::getCount))));
上述代码中,我们把人按照名字和年龄分组。得到一个Map,key是名字,value是一个新的Map,key是年龄,value是这个年龄下所有这个名字的Person对象的count属性之和。
四、分组求和的性能
在进行大数据量的分组求和时,使用Stream API的效率更高,因为可以充分利用多核CPU和支持云计算的原生线程级别并行处理流。另外,使用Stream API的方式代码简洁、易于维护,更加容易实现操作的复合和流水线,并且具有高度的可读性。
相比较于传统的编程方法,使用Java8中的分组求和操作可以明显提高开发效率和代码质量。