StreamAPI（二）用流收集数据

Java8中提供了Collectors类来做收集器。以下详情都是使用流中的collect方法接收Collector接口的实现。

一、规约和汇总

1. 查找流中的最大值和最小值

//Collectors提供了maxBy和minBy来计算流中的最大值和最小值Comparator dishCaloriesComparator = Comparator.comparingInt(Dish::getCalories);Optional mostCalorieDish = menu.stream() .collect(maxBy(dishCaloriesComparator));

2. 汇总
   提供了Collectors.summingInt、Collectors.summingLong、Collectors.summingDouble来实现累加操作。
   还有Collectors.averagingInt来计算平均，Collectors.summarizingInt统计综合值等。

3. 连接字符串
   Collectors.joining()或者者Collectors.joining(“字符”)

4. 广义的规约汇总
   Collectors.reducing，与reduce方法相比，这种方法更易于并行解决，介绍见《Java8实战》P117

二、分组

Collectors.groupingBy工厂方法返回的收集器可以进行分组，分组的结果为一个Map。

三、分区

分区是分组的特殊情况：由一个谓词（返回一个布尔值的函数）作为分区函数，它称为分区函数。返回结果Map中包含true一组和false一组。分区函数为：Collectors.partitioningBy。

四、收集器接口

//在下面的接口中：//T是流中要收集的项目的泛型，A是累加器的类型，累加器是在收集过程中用于累计部分结果的对象。//R是收集操作得到的对象（通常但并不肯定是集合）类型public interface Collector { //建立新的容器，返回一个结果为空的Supplier，即无参数函数 Supplier supplier(); //将元素增加到容器，返回执行归约操作的函数 BiConsumer accumulator(); //对容器结果应用最终转换 Function finisher(); //合并两个结果的容器 BinaryOperator combiner(); //返回一个不可变的Characteristics集合，其定义了收集器的行为 Set characteristics();}

补充：Characteristics是一个包含三个项目的枚举。

• UNORDERED——归约结果不受流中项目的遍历和累积顺序的影响。
• CONCURRENT——accumulator函数可以从多个线程同时调用，且该收集器可以并行归约流。假如收集器没有标为UNORDERED，那它仅在用于无序数据源时才可以并行归约。
• IDENTITY_FINISH——这表明完成器方法返回的函数是一个恒等函数，可以跳过。这种情况下，累加器对象将会直接用作归约过程的最终结果。这也意味着，将累加器A不加检 15 查地转换为结果R是安全的。

自己设置接口实现：

ToListCollector接口实现