作者：一直都在囚禁 | 来源：互联网 | 2023-06-20 12:38
Collector常见用法常用形式为:.collect(Collectors.toList())collect()是Stream的方法Collectors是收集器Collector
Collector常见用法
| 常用形式为: .collect(Collectors.toList()) collect()是Stream的方法 Collectors 是收集器Collector 的工厂方法,提供了一些常用的收集器 |
比如
常用收集器概要
| 收集器 | 行为 |
|---|
toList() | 将元素收集到一个 List 中。 |
toSet() | 将元素收集到一个 Set 中。 |
toCollection() | 将元素收集到一个 Collection 中。 |
toMap(...) | 将元素收集到一个 Map 中&＃xff0c;依据提供的映射函数将元素转换为键/值。 |
summingInt(ToIntFunction) | 给定值序列进行求和&＃xff08;还有 long 和 double 版本&＃xff09; |
summarizingInt(ToIntFunction) | 给定值序列计算统计信息 sum、 min、 max、 count 和 average &＃xff08;还有 long 和 double 版本&＃xff09; |
reducing(...) | 用于归约计算&＃xff08;通常用作下游收集器&＃xff0c;比如用于 groupingBy 或者partitioningBy 下游&＃xff09; |
partitioningBy(...) | 按照predicate分为两组 |
groupingBy(...) | 将元素分组 |
| maxBy(Comparator comparator) | 最大值 |
minBy(Comparator comparator) | 最小值 |
mapping(Function, Collector) | 将提供的映射函数应用于每个元素&＃xff0c;并使用指定的下游收集器&＃xff08;通常用作下游收集器本身&＃xff0c;比如用于 groupingBy&＃xff09;进行处理。 |
joining() | 假设元素为 String 类型&＃xff0c;将这些元素联结到一个字符串中&＃xff08;或许使用分隔符、前缀和后缀&＃xff09;。 |
counting() | 计算元素数量。&＃xff08;通常用作下游收集器。&＃xff09; |
| averagingInt(ToIntFunction) | 平均数 &＃xff08;还有 long 和 double 版本&＃xff09; |
收集器参数列表
| toList() |
| toSet() |
| toCollection(Supplier) |
| counting() |
| collectingAndThen(Collector, Function) |
| summingInt(ToIntFunction) summingLong(ToLongFunction) summingDouble(ToDoubleFunction) |
| maxBy(Comparator) |
| minBy(Comparator) |
| reducing(BinaryOperator) reducing(T, BinaryOperator) reducing(U, Function, BinaryOperator) |
| joining() joining(CharSequence) joining(CharSequence, CharSequence, CharSequence) |
| mapping(Function, Collector) |
| toMap(Function, Function) toMap(Function, Function, BinaryOperator) toMap(Function, Function, BinaryOperator, Supplier) toConcurrentMap(Function, Function) toConcurrentMap(Function, Function, BinaryOperator) toConcurrentMap(Function, Function, BinaryOperator, Supplier) |
| groupingBy(Function) groupingBy(Function, Supplier, Collector) groupingBy(Function, Collector) groupingByConcurrent(Function) groupingByConcurrent(Function, Supplier, Collector) groupingByConcurrent(Function, Collector) |
| partitioningBy(Predicate) partitioningBy(Predicate, Collector) |
| averagingDouble(ToDoubleFunction) averagingInt(ToIntFunction) averagingLong(ToLongFunction) |
| summarizingDouble(ToDoubleFunction) summarizingInt(ToIntFunction) summarizingLong(ToLongFunction) |
收集器详解
Collector
T - 输入类型
A - 在收集过程中用于累积部分结果的对象类型
R - 返回类型
| mutable reduction的一些场景: 将元素聚集到集合中 使用StringBuilder连接字符串 计算有关元素的汇总信息&＃xff0c;如sum、min、max或平均值 计算“主表”摘要&＃xff0c;如“卖方的最大价值交易”等 类Collectors提供了许多常见的reduce实现 |
收集器构成
收集器是由四个函数约定构成&＃xff0c;它们一起工作&＃xff0c;将条目汇集到一个可变的结果容器中&＃xff0c;并可选择性地对结果执行最终转换。
| 1. 创建一个新的结果容器(supplier()) 2. 将一个新的数据元素合并到一个结果容器中(accumulator()) 3. 将两个结果容器合并成一个(combiner()) (非必然运行 可能在并行流且Collector不具备CONCURRENT 时执行的 ) 4. 在容器上执行一个可选的最终转换 (finisher()) (非必然运行 中间结果与最终结果类型是否一致决定是否运行 IDENTITY_FINISH用来标志 ) |
属性特征字段
| 特征值是Collector的特征值,用于描述Collecto本身r的,不是其他含义 |
| Set characteristics() 方法可以访问 |
| Collector.Characteristics CONCURRENT 表示中间结果只有一个&＃xff0c;即使在并行流的情况下 所以只有在并行流且收集器不具备CONCURRENT特性时&＃xff0c;combiner方法返回的lambda表达式才会执行 如果收集器没有标为UNORDERED&＃xff0c;那它仅在用于无序数据源时才可以并行归约 |
| Collector.Characteristics UNORDERED 表示不承诺按照操作顺序排列 |
Collector.Characteristics IDENTITY_FINISH
表示中间结果容器类型与最终结果类型一致&＃xff0c;此时finiser方法不会被调用 |
静态工厂方法
根据提供的给定条件创建 Collector
Collector 就是归约运算操作的一种抽象
首先要理解归约reduce的含义 也就是归纳转换成另外一种形式
| 想要进行归约运算,你先给出一个初始容器,作为中间结果容器 然后再给出迭代运算逻辑 也就是要如何归约 归约的逻辑 就是在这里 结果计算到中间结果容器中 针对于并行计算还需要一个合并的方式 中间结果肯定是为了方便计算,如果你最终想要的不是这种类型,我还可以给你转换下 |
Collector用 类型TAR 和四个方法将归约的过程逻辑化
Collector工厂Collectors
提供了Collector的一些常用实现 比如
// 获取所有的name转换到List中
List list &＃61; people.stream().map(Person::getName).collect(Collectors.toList());// 获取所有的name转换到Set中
Set set &＃61; people.stream().map(Person::getName).collect(Collectors.toCollection(TreeSet::new));
// 元素转换为String 并且将他们通过", " 连接起来
String joined &＃61; things.stream()
.map(Object::toString)
.collect(Collectors.joining(", "));
//计算员工薪水之和
int total &＃61; employees.stream()
.collect(Collectors.summingInt(Employee::getSalary)));
// 按照部门对员工进行分组
Map> byDept
&＃61; employees.stream()
.collect(Collectors.groupingBy(Employee::getDepartment));
// 计算部门薪资和
Map totalByDept
&＃61; employees.stream()
.collect(Collectors.groupingBy(Employee::getDepartment,
Collectors.summingInt(Employee::getSalary)));
// 按照成绩是否通过把学生分为两组
Map> passingFailing &＃61;
students.stream()
.collect(Collectors.partitioningBy(s -> s.getGrade() >&＃61; PASS_THRESHOLD));
Collectors 中有一个静态内部类CollectorImpl 实现了CollectorImpl
预置的一些收集器都是通过CollectorImpl 返回的
/**
* Simple implementation class for {&＃64;code Collector}.
*
* &＃64;param the type of elements to be collected
* &＃64;param the type of the result
*/
static class CollectorImpl implements Collector {
private final Supplier supplier;
private final BiConsumer accumulator;
private final BinaryOperator combiner;
private final Function finisher;
private final Set characteristics;CollectorImpl(Supplier supplier,
BiConsumer accumulator,
BinaryOperator combiner,
Function finisher,
Set characteristics) {
this.supplier &＃61; supplier;
this.accumulator &＃61; accumulator;
this.combiner &＃61; combiner;
this.finisher &＃61; finisher;
this.characteristics &＃61; characteristics;
}CollectorImpl(Supplier supplier,
BiConsumer accumulator,
BinaryOperator combiner,
Set characteristics) {
this(supplier, accumulator, combiner, castingIdentity(), characteristics);
}&＃64;Override
public BiConsumer accumulator() {
return accumulator;
}&＃64;Override
public Supplier supplier() {
return supplier;
}
&＃64;Override
public BinaryOperator combiner() {
return combiner;
}
&＃64;Override
public Function finisher() {
return finisher;
}
&＃64;Override
public Set characteristics() {
return characteristics;
}
}
Collectors中内置的 关于Collector characteristics 特性的组合值
看一个例子
Collector> toList() {
return new CollectorImpl<>( (Supplier>) ArrayList::new,
List::add,
(left, right) -> { left.addAll(right); return left; },
CH_ID);
}
TAR分别是 T ? List 也就是处理元素为T类型 返回结果为List 中间结果随意
ArrayList::new 返回List 作为中间结果,显然,跟返回结果一样,不需要调用finisher了
归约方式为 使用List.add方法不断地将集合中的元素添加到中间结果中
合并方式为直接将一个List addAll到另一个list 并且返回最终结果
因为不需要调用finisher 设置下特征 CH_ID
所以说只要按规矩实现了四个方法以及设置characteristics 就可以实现一个Collector
你可以使用Stream中
调用Collectors 提供的一些Collector 或者你自己定义的
你还可以使用Stream中
直接传递参数,显然并不是很直观 建议能不用就别用了
![[大整数乘法] java代码实现](https://img1.php1.cn/3cd4a/24c6f/9f3/0133bb25da242824.jpeg)
京公网安备 11010802041100号