Java8 Stream Collectors收集器使用方法解析
Collectors.toMap:
StudentstudentA=newStudent("20190001","小明"); StudentstudentB=newStudent("20190002","小红"); StudentstudentC=newStudent("20190003","小丁"); //Function.identity()获取这个对象本身,那么结果就是Map即id->student //串行收集 Stream.of(studentA,studentB,studentC) .collect(Collectors.toMap(Student::getId,Function.identity())); //并发收集 Stream.of(studentA,studentB,studentC) .parallel() .collect(Collectors.toConcurrentMap(Student::getId,Function.identity())); //================================================================================ //Map 即id->name //串行收集 Stream.of(studentA,studentB,studentC) .collect(Collectors.toMap(Student::getId,Student::getName)); //并发收集 Stream.of(studentA,studentB,studentC) .parallel() .collect(Collectors.toConcurrentMap(Student::getId,Student::getName));
那么如果key重复的该怎么处理?这里我们假设有两个id相同Student,如果他们id相同,在转成Map的时候,取name大一个,小的将会被丢弃。
//Map//maxby==sordBy倒序minByor.maxBy(Comparator.comparing(User::getName).reversed()))); Stream.of(studentA,studentB,studentC) .collect(Collectors .toMap(Student::getId, Function.identity(), BinaryOperator .maxBy(Comparator.comparing(Student::getName)))); //可能上面比较复杂,这编写一个命令式 //Map Stream.of(studentA,studentB,studentC) .collect(Collectors .toMap(Student::getId, Function.identity(), (s1,s2)->{ //这里使用compareTo方法s1>s2会返回1,s1==s2返回0,否则返回-1 if(((Student)s1).name.compareTo(((Student)s2).name)<-1){ returns2; }else{ returns1; } }));
如果不想使用默认的HashMap或者ConcurrentHashMap,第三个重载方法还可以使用自定义的Map对象(Map工厂)。
//自定义LinkedHashMap //MapStream.of(studentA,studentB,studentC) .collect(Collectors .toMap(Student::getId, Function.identity(), BinaryOperator .maxBy(Comparator.comparing(Student::getName)), LinkedHashMap::new));
Collectors.groupingBy()和Collectors.groupingByConcurrent(),这两者区别也仅是单线程和多线程的使用场景。为什么要groupingBy归类为前后处理呢?groupingBy是在数据收集前分组的,再将分好组的数据传递给下游的收集器。
这是groupingBy最长的参数的函数classifier是分类器,mapFactorymap的工厂,downstream下游的收集器,正是downstream的存在,可以在数据传递个下游之前做很多的骚操作。
publicstatic> Collector groupingBy(Functionclassifier, Supplier mapFactory, Collectordownstream)
示例:这里将一组数整型数分为正数、负数、零,groupingByConcurrent()的参数也是跟它一样的就不举例了。
//Map> Stream.of(-6,-7,-8,-9,1,2,3,4,5,6) .collect(Collectors.groupingBy(integer->{ if(integer<0){ return"小于"; }elseif(integer==0){ return"等于"; }else{ return"大于"; } })); //Map > //自定义下游收集器 Stream.of(-6,-7,-8,-9,1,2,3,4,5,6) .collect(Collectors.groupingBy(integer->{ if(integer<0){ return"小于"; }elseif(integer==0){ return"等于"; }else{ return"大于"; } },Collectors.toSet())); //Map > //自定义map容器和下游收集器 Stream.of(-6,-7,-8,-9,1,2,3,4,5,6) .collect(Collectors.groupingBy(integer->{ if(integer<0){ return"小于"; }elseif(integer==0){ return"等于"; }else{ return"大于"; } },LinkedHashMap::new,Collectors.toSet()));
Collectors.partitioningBy()
字面意思话就叫分区好了,但是partitioningBy最多只能将数据分为两部分,因为partitioningBy分区的依据Predicate,而Predicate只会有true和false两种结果,所有partitioningBy最多只能将数据分为两组。partitioningBy除了分类器与groupingBy不一样外,其他的参数都相同。
示例:
//Map> Stream.of(0,1,0,1) .collect(Collectors.partitioningBy(integer->integer==0)); //Map > //自定义下游收集器 Stream.of(0,1,0,1) .collect(Collectors.partitioningBy(integer->integer==0,Collectors.toSet()));
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。