/** * @author 陈杨 */@SpringBootTest@RunWith(SpringRunner.class)public class CollectorsDetail { private Listnames; private List students; private List
> snames; @Before public void init() { names = Arrays.asList("Kirito", "Asuna", "Sinon", "Yuuki", "Alice"); snames = Arrays.asList(Collections.singletonList("Kirito"), Collections.singletonList("Asuna"), Collections.singletonList("Sinon"), Collections.singletonList("Yuuki"), Collections.singletonList("Alice")); students = new Students().init(); } @Test public void testCollectorsDetail() {
一、静态工厂类Collectors 实现方式
// 一、静态工厂类Collectors 实现方式// Collectors 静态工厂类 最终由CollectorImpl实现// 1、 通过CollectorImpl实现// 2、 通过reducing()实现---> reducing()底层由CollectorImpl实现// Collectors.toList() 是 Collectors.toCollection()的一种具化表现形式// Collectors.joining() 使用StringBuilder.append 拼接字符串
二、静态工厂类Collectors 常用收集器
// 二、静态工厂类Collectors 常用收集器/* 返回一个(不可修改)unmodifiable List的ArrayList 按照相遇的顺序encounter order@since 10@SuppressWarnings("unchecked")public staticCollector > toUnmodifiableList() { return new CollectorImpl<>((Supplier
>) ArrayList::new, List::add, (left, right) -> { left.addAll(right); return left; }, list -> (List )List.of(list.toArray()), CH_NOID);}*//* 返回一个(不可修改)unmodifiable Set的HashSet 无序@since 10@SuppressWarnings("unchecked")public static Collector > toUnmodifiableSet() { return new CollectorImpl<>((Supplier >) HashSet::new, Set::add, (left, right) -> { if (left.size() < right.size()) { right.addAll(left); return right; } else { left.addAll(right); return left; } }, set -> (Set )Set.of(set.toArray()), CH_UNORDERED_NOID);}*//* 返回一个flatMapping扁平化mapper处理后 由downstream收集的 累加器处理的结果合并 单线程@since 9public static Collector flatMapping(Function > mapper, Collector downstream) { BiConsumer downstreamAccumulator = downstream.accumulator(); return new CollectorImpl<>(downstream.supplier(), (r, t) -> { try (Stream result = mapper.apply(t)) { if (result != null) result.sequential().forEach(u -> downstreamAccumulator.accept(r, u)); } }, downstream.combiner(), downstream.finisher(), downstream.characteristics());}*//* 对符合Predicate预期结果 进行过滤filtering 使用downstream 收集元素@since 9public static Collector filtering(Predicate predicate, Collector downstream) { BiConsumer downstreamAccumulator = downstream.accumulator(); return new CollectorImpl<>(downstream.supplier(), (r, t) -> { if (predicate.test(t)) { downstreamAccumulator.accept(r, t); } }, downstream.combiner(), downstream.finisher(), downstream.characteristics());}*//* 使用Map映射key-->keyMapper-->Key value-->valueMapper-->Value 对映射后的结果进行组装entrySet-->Map (unmodifiable Map)@since 10@SuppressWarnings({"rawtypes", "unchecked"})public static Collector > toUnmodifiableMap(Function keyMapper, Function valueMapper) { Objects.requireNonNull(keyMapper, "keyMapper"); Objects.requireNonNull(valueMapper, "valueMapper"); return collectingAndThen( toMap(keyMapper, valueMapper), map -> (Map )Map.ofEntries(map.entrySet().toArray(new Map.Entry[0])));}*//* 使用Map映射key-->keyMapper-->Key value-->valueMapper-->Value mergeFunction 对相同key 映射后的进行Value 合并操作 对映射后的结果进行组装entrySet-->Map (unmodifiable Map)@since 10@SuppressWarnings({"rawtypes", "unchecked"})public static Collector > toUnmodifiableMap(Function keyMapper, Function valueMapper, BinaryOperator mergeFunction) { Objects.requireNonNull(keyMapper, "keyMapper"); Objects.requireNonNull(valueMapper, "valueMapper"); Objects.requireNonNull(mergeFunction, "mergeFunction"); return collectingAndThen( toMap(keyMapper, valueMapper, mergeFunction, HashMap::new), map -> (Map )Map.ofEntries(map.entrySet().toArray(new Map.Entry[0])));}*/
// Collectors 收集器System.out.println("-----------------------------------------\n");// 使用ArrayList集合 按照流中元素排列先后顺序 进行添加操作ListunmodifiableList = names.stream().collect(Collectors.toUnmodifiableList());System.out.println(unmodifiableList);System.out.println("---------------------------------------\n");// 使用HashSet集合 对流中元素顺序 进行添加操作Set unmodifiableSet = names.stream().collect(Collectors.toUnmodifiableSet());System.out.println(unmodifiableSet);System.out.println("---------------------------------------\n");// 将集合扁平化展开 对其中的字符串的每个字母 进行大写转换 使用ArrayList对转换后的结果进行收集List strings = snames.stream() .collect(Collectors.flatMapping(list -> list.stream().map(String::toUpperCase), Collectors.toList()));System.out.println(strings);System.out.println("---------------------------------------\n");// 对流中元素进行遍历 对符合预期要求的元素 使用ArrayList集合存放List filteringPredicate = names.stream().collect(Collectors.filtering("Kirito"::equals, Collectors.toList()));System.out.println(filteringPredicate);System.out.println("---------------------------------------\n");// 对流中元素进行遍历 对key-->keyMapper value-->valueMapper 映射 得到Map集合Map > listMap = students.stream() .collect(Collectors.toUnmodifiableMap(Student::getId, student -> { List stus = new ArrayList<>(); stus.add(student); return stus; }));System.out.println(listMap);System.out.println("---------------------------------------\n");// 对流中元素进行遍历 对key-->keyMapper-->Key value-->valueMapper-->Value 映射// 对满足相同Key的元素 Value进行合并Map lengthName = names.stream() .collect(Collectors.toUnmodifiableMap(String::length, String::toString, (str1, str2) -> str1 + "\t" + str2));System.out.println(lengthName);System.out.println("---------------------------------------\n");
三、groupingBy分组
// 三、groupingBy分组// 分组 groupingBy// 对T元素按 key进行分组 --> 分组的依据 classifier--> 分组后的集合 value--> 得到 Map/*Returns a {@code Collector} implementing a "group by" operation oninput elements of type {@code T}, grouping elements according to a classification function, and returning the results in a {@code Map}. The classification function maps elements to some key type {@code K}.The collector produces a {@code Map
>} whose keys are thevalues resulting from applying the classification function to the inputelements, and whose corresponding values are {@code List}s containing the input elements which map to the associated key under the classificationfunction. There are no guarantees on the type, mutability, serializability, orthread-safety of the {@code Map} or {@code List} objects returned.*//* 按照key对T进行classifier分组 使用List集合收集分组结果 单线程 线程安全public static
Collector >>groupingBy(Function classifier) { return groupingBy(classifier, toList());}*//* 按照key对T进行classifier分组 使用自定义收集器downstream 收集分组结果 单线程 线程安全public static Collector > groupingBy(Function classifier, Collector downstream) { return groupingBy(classifier, HashMap::new, downstream);}*//* 按照key对T进行classifier分组 使用自定义mapFactory 重置downstream的CollectorImpl实现 使用自定义收集器downstream 收集分组结果 单线程 线程安全public static >Collector groupingBy(Function classifier, Supplier mapFactory, Collector downstream) { Supplier downstreamSupplier = downstream.supplier(); BiConsumer downstreamAccumulator = downstream.accumulator(); BiConsumer
// 分组System.out.println("-----------------------------------------\n");// select * from students group by sex ;Map> sexStudent = students.stream().collect(Collectors.groupingBy(Student::getSex));System.out.println(sexStudent);System.out.println("-----------------------------------------\n");// select sex, count(*) from students group by sex ;Map sexCount = students.stream().collect(Collectors.groupingBy(Student::getSex, Collectors.counting()));System.out.println(sexCount);System.out.println("-----------------------------------------\n");// select sex,avg(salary) from students group by sex ;Map avgSexSalary = students.stream().collect (Collectors.groupingBy(Student::getSex, Collectors.averagingDouble(Student::getSalary)));System.out.println(avgSexSalary);System.out.println("-----------------------------------------\n");// 嵌套分组 先根据sex分组 再对结果按照addr进行分组Map >> NestedGroupBy = students.stream() .collect(Collectors.groupingBy(Student::getSex, Collectors.groupingBy(Student::getAddr)));System.out.println(NestedGroupBy);System.out.println("-----------------------------------------\n");// 使用自定义收集器downstream 按性别分组 使用HashSet进行 结果收集Map > sexHashSet = students.stream() .collect(Collectors.groupingBy(Student::getSex, Collectors.toCollection(HashSet::new)));System.out.println(sexHashSet);System.out.println("-----------------------------------------\n");// 使用自定义收集器downstream 按性别分组 使用HashSet进行 结果收集 重置CollectorImpl实现Map > sexCustomCollectorImpl = students.stream() .collect(Collectors.groupingBy(Student::getSex, Hashtable::new, Collectors.toCollection(HashSet::new)));System.out.println(sexCustomCollectorImpl);System.out.println("-----------------------------------------\n");
四、groupingByConcurrent分组
// 四、groupingByConcurrent分组 // 分组 groupingByConcurrent // 流的适用条件: // 无序 Collector.Characteristics.UNORDERED // 并发 Collector.Characteristics.CONCURRENT // This is a {@link Collector.Characteristics#CONCURRENT concurrent} and // {@link Collector.Characteristics#UNORDERED unordered} Collector. /* 按照key对T进行classifier分组 使用List集合收集分组结果 public staticCollector >> groupingByConcurrent(Function classifier) { return groupingByConcurrent(classifier, ::new, toList()); }*//* 按照key对T进行classifier分组 使用自定义收集器downstream 收集分组结果public static Collector > groupingByConcurrent(Function classifier, Collector downstream) { return groupingByConcurrent(classifier, ConcurrentHashMap::new, downstream); }*/ /* 按照key对T进行classifier分组 使用自定义累加器mapFactory 重置downstream的CollectorImpl实现 使用自定义收集器downstream 收集分组结果 public static > Collector groupingByConcurrent(Function classifier, Supplier mapFactory, Collector downstream) { Supplier downstreamSupplier = downstream.supplier(); BiConsumer downstreamAccumulator = downstream.accumulator(); BinaryOperator > merger = Collectors. >mapMerger(downstream.combiner()); @SuppressWarnings("unchecked") Supplier > mangledFactory = (Supplier >) mapFactory; BiConsumer , T> accumulator; if (downstream.characteristics().contains(Collector.Characteristics.CONCURRENT)) { accumulator = (m, t) -> { K key = Objects.requireNonNull(classifier.apply(t), "element cannot be mapped to a null key"); A resultContainer = m.computeIfAbsent(key, k -> downstreamSupplier.get()); downstreamAccumulator.accept(resultContainer, t); }; } else { accumulator = (m, t) -> { K key = Objects.requireNonNull(classifier.apply(t), "element cannot be mapped to a null key"); A resultContainer = m.computeIfAbsent(key, k -> downstreamSupplier.get()); // 多个操作-->同时操作同一个结果容器-->同一时间,有且只有一个进行实际操作-->线程同步 synchronized (resultContainer) { downstreamAccumulator.accept(resultContainer, t); } }; } if (downstream.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)) { return new CollectorImpl<>(mangledFactory, accumulator, merger, CH_CONCURRENT_ID); } else { @SuppressWarnings("unchecked") Function downstreamFinisher = (Function ) downstream.finisher(); Function , M> finisher = intermediate -> { intermediate.replaceAll((k, v) -> downstreamFinisher.apply(v)); @SuppressWarnings("unchecked") M castResult = (M) intermediate; return castResult; }; return new CollectorImpl<>(mangledFactory, accumulator, merger, finisher, CH_CONCURRENT_NOID); } }*/
// 分组 无序 并发System.out.println("-----------------------------------------\n");// 按性别分组 使用ArrayList进行 结果收集ConcurrentMap> sexStudentConcurrent = students.stream() .collect(Collectors.groupingByConcurrent(Student::getSex));System.out.println(sexStudentConcurrent);System.out.println("-----------------------------------------\n");// 使用自定义收集器downstream 按性别分组 使用HashSet进行 结果收集ConcurrentMap > sexHashSetConcurrent = students.stream() .collect(Collectors.groupingByConcurrent(Student::getSex, Collectors.toCollection(HashSet::new)));System.out.println(sexHashSetConcurrent);System.out.println("-----------------------------------------\n");// 使用自定义收集器downstream 按性别分组 使用HashSet进行 结果收集 重置CollectorImpl实现ConcurrentReferenceHashMap > sexCustomCollectorImplConcurrent = students.stream().collect(Collectors.groupingByConcurrent(Student::getSex, ConcurrentReferenceHashMap::new, Collectors.toCollection(HashSet::new)));System.out.println(sexCustomCollectorImplConcurrent);System.out.println("-----------------------------------------\n");
五、partitioningBy分区
// 五、partitioningBy分区// 分区 partitioningBy/* 对满足预期的条件 进行分区 使用ArrayList 进行结果的收集public staticCollector >> partitioningBy(Predicate predicate) { return partitioningBy(predicate, toList());}*//* 对满足预期的条件 进行分区 使用自定义收集器downstream 进行结果的收集public static Collector > partitioningBy(Predicate predicate, Collector downstream) { BiConsumer downstreamAccumulator = downstream.accumulator(); BiConsumer , T> accumulator = (result, t) -> downstreamAccumulator.accept(predicate.test(t) ? result.forTrue : result.forFalse, t); BinaryOperator op = downstream.combiner(); BinaryOperator > merger = (left, right) -> new Partition<>(op.apply(left.forTrue, right.forTrue), op.apply(left.forFalse, right.forFalse)); Supplier > supplier = () -> new Partition<>(downstream.supplier().get(), downstream.supplier().get()); if (downstream.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)) { return new CollectorImpl<>(supplier, accumulator, merger, CH_ID); } else { Function , Map > finisher = par -> new Partition<>(downstream.finisher().apply(par.forTrue), downstream.finisher().apply(par.forFalse)); return new CollectorImpl<>(supplier, accumulator, merger, finisher, CH_NOID); }}*/
// 分区 System.out.println("-----------------------------------------\n"); // select * from students partition by (addr == Sword Art Online) ; Map> addrPartition = students.stream().collect (Collectors.partitioningBy(student -> student.getAddr().equals("Sword Art Online"))); System.out.println(addrPartition); System.out.println("-----------------------------------------\n"); // 嵌套分区 先根据sex分区 再对结果按照addr进行分区 Map >> NestedPartiton = students.stream() .collect(Collectors.partitioningBy(student -> student.getSex().equals("Male"), Collectors.partitioningBy(student -> student.getAddr().equals("Sword Art Online")))); System.out.println(NestedPartiton); System.out.println("-----------------------------------------\n"); // 使用自定义downstream收集器分区 Map > addrCustomPartition = students.stream().collect(Collectors.partitioningBy (student -> student.getAddr().equals("Sword Art Online"), Collectors.toCollection(HashSet::new))); System.out.println(addrCustomPartition); System.out.println("-----------------------------------------\n"); }}
六、测试结果
. ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \ \\/ ___)| |_)| | | | | || (_| | ) ) ) ) ' |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.1.2.RELEASE)2019-02-20 16:58:15.870 INFO 13392 --- [ main] c.j.d.java8.Stream.CollectorsDetail : Starting CollectorsDetail on DESKTOP-87RMBG4 with PID 13392 (started by 46250 in E:\IdeaProjects\design)2019-02-20 16:58:15.871 INFO 13392 --- [ main] c.j.d.java8.Stream.CollectorsDetail : No active profile set, falling back to default profiles: default2019-02-20 16:58:16.383 INFO 13392 --- [ main] c.j.d.java8.Stream.CollectorsDetail : Started CollectorsDetail in 0.708 seconds (JVM running for 1.421)-----------------------------------------[Kirito, Asuna, Sinon, Yuuki, Alice]---------------------------------------[Yuuki, Asuna, Kirito, Sinon, Alice]---------------------------------------[KIRITO, ASUNA, SINON, YUUKI, ALICE]---------------------------------------[Kirito]---------------------------------------{5=[Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)], 4=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8)], 3=[Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8)], 2=[Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)], 1=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}---------------------------------------{6=Kirito, 5=Asuna Sinon Yuuki Alice}--------------------------------------------------------------------------------{Female=[Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)], Male=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}-----------------------------------------{Female=4, Male=1}-----------------------------------------{Female=9.99999999E8, Male=9.99999999E8}-----------------------------------------{Female={Alicization=[Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)], Sword Art Online=[Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)], Gun Gale Online=[Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8)], Alfheim Online=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8)]}, Male={Sword Art Online=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}}-----------------------------------------{Female=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8), Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)], Male=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}-----------------------------------------{Female=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8), Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)], Male=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}----------------------------------------------------------------------------------{Male=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)], Female=[Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)]}-----------------------------------------{Male=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)], Female=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8), Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)]}-----------------------------------------{Female=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8), Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)], Male=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}----------------------------------------------------------------------------------{false=[Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)], true=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8), Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)]}-----------------------------------------{false={false=[Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)], true=[Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8)]}, true={false=[], true=[Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}}-----------------------------------------{false=[Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)], true=[Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8), Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]}-----------------------------------------