摘要:陈杨一静态工厂类实现方式一静态工厂类实现方式静态工厂类最终由实现通过实现通过实现底层由实现是的一种具化表现形式使用拼接字符串二静态工厂类常用收集器二静态工厂类常用收集器返回一个不可修改的按照相遇的顺序返回一个不可修改的无序返回
/** * @author 陈杨 */ @SpringBootTest @RunWith(SpringRunner.class) public class CollectorsDetail { private List一、静态工厂类Collectors 实现方式names; 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 静态工厂类 最终由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 9 public static Collector flatMapping(Function super T, ? extends Stream extends U>> mapper, Collector super U, A, R> downstream) { BiConsumer downstreamAccumulator = downstream.accumulator(); return new CollectorImpl<>(downstream.supplier(), (r, t) -> { try (Stream extends U> 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 9 public static Collector filtering(Predicate super T> predicate, Collector super T, A, R> 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 super T, ? extends K> keyMapper, Function super T, ? extends U> 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 super T, ? extends K> keyMapper, Function super T, ? extends U> 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("----------------------------------------- "); // 使用ArrayList集合 按照流中元素排列先后顺序 进行添加操作 List三、groupingBy分组unmodifiableList = names.stream().collect(Collectors.toUnmodifiableList()); System.out.println(unmodifiableList); System.out.println("--------------------------------------- "); // 使用HashSet集合 对流中元素顺序 进行添加操作 Set unmodifiableSet = names.stream().collect(Collectors.toUnmodifiableSet()); System.out.println(unmodifiableSet); System.out.println("--------------------------------------- "); // 将集合扁平化展开 对其中的字符串的每个字母 进行大写转换 使用ArrayList对转换后的结果进行收集 List strings = snames.stream() .collect(Collectors.flatMapping(list -> list.stream().map(String::toUpperCase), Collectors.toList())); System.out.println(strings); System.out.println("--------------------------------------- "); // 对流中元素进行遍历 对符合预期要求的元素 使用ArrayList集合存放 List filteringPredicate = names.stream().collect(Collectors.filtering("Kirito"::equals, Collectors.toList())); System.out.println(filteringPredicate); System.out.println("--------------------------------------- "); // 对流中元素进行遍历 对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("--------------------------------------- "); // 对流中元素进行遍历 对key-->keyMapper-->Key value-->valueMapper-->Value 映射 // 对满足相同Key的元素 Value进行合并 Map lengthName = names.stream() .collect(Collectors.toUnmodifiableMap(String::length, String::toString, (str1, str2) -> str1 + " " + str2)); System.out.println(lengthName); System.out.println("--------------------------------------- ");
// 三、groupingBy分组 // 分组 groupingBy // 对T元素按 key进行分组 --> 分组的依据 classifier--> 分组后的集合 value--> 得到 Map/* Returns a {@code Collector} implementing a "group by" operation on input 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 the values resulting from applying the classification function to the input elements, and whose corresponding values are {@code List}s containing the input elements which map to the associated key under the classification function. There are no guarantees on the type, mutability, serializability, or thread-safety of the {@code Map} or {@code List} objects returned.*/ /* 按照key对T进行classifier分组 使用List集合收集分组结果 单线程 线程安全 public static
Collector >> groupingBy(Function super T, ? extends K> classifier) { return groupingBy(classifier, toList()); }*/ /* 按照key对T进行classifier分组 使用自定义收集器downstream 收集分组结果 单线程 线程安全 public static Collector > groupingBy(Function super T, ? extends K> classifier, Collector super T, A, D> downstream) { return groupingBy(classifier, HashMap::new, downstream); }*/ /* 按照key对T进行classifier分组 使用自定义mapFactory 重置downstream的CollectorImpl实现 使用自定义收集器downstream 收集分组结果 单线程 线程安全 public static > Collector groupingBy(Function super T, ? extends K> classifier, Supplier mapFactory, Collector super T, A, D> downstream) { Supplier downstreamSupplier = downstream.supplier(); BiConsumer downstreamAccumulator = downstream.accumulator(); BiConsumer
// 分组 System.out.println("----------------------------------------- "); // select * from students group by sex ; Map四、groupingByConcurrent分组> sexStudent = students.stream().collect(Collectors.groupingBy(Student::getSex)); System.out.println(sexStudent); System.out.println("----------------------------------------- "); // 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("----------------------------------------- "); // 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("----------------------------------------- "); // 嵌套分组 先根据sex分组 再对结果按照addr进行分组 Map >> NestedGroupBy = students.stream() .collect(Collectors.groupingBy(Student::getSex, Collectors.groupingBy(Student::getAddr))); System.out.println(NestedGroupBy); System.out.println("----------------------------------------- "); // 使用自定义收集器downstream 按性别分组 使用HashSet进行 结果收集 Map > sexHashSet = students.stream() .collect(Collectors.groupingBy(Student::getSex, Collectors.toCollection(HashSet::new))); System.out.println(sexHashSet); System.out.println("----------------------------------------- "); // 使用自定义收集器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("----------------------------------------- ");
// 四、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 super T, ? extends K> classifier) { return groupingByConcurrent(classifier, ::new, toList()); }*/ /* 按照key对T进行classifier分组 使用自定义收集器downstream 收集分组结果 public static Collector > groupingByConcurrent(Function super T, ? extends K> classifier, Collector super T, A, D> downstream) { return groupingByConcurrent(classifier, ConcurrentHashMap::new, downstream); }*/ /* 按照key对T进行classifier分组 使用自定义累加器mapFactory 重置downstream的CollectorImpl实现 使用自定义收集器downstream 收集分组结果 public static > Collector groupingByConcurrent(Function super T, ? extends K> classifier, Supplier mapFactory, Collector super T, A, D> 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("----------------------------------------- "); // 按性别分组 使用ArrayList进行 结果收集 ConcurrentMap五、partitioningBy分区> sexStudentConcurrent = students.stream() .collect(Collectors.groupingByConcurrent(Student::getSex)); System.out.println(sexStudentConcurrent); System.out.println("----------------------------------------- "); // 使用自定义收集器downstream 按性别分组 使用HashSet进行 结果收集 ConcurrentMap > sexHashSetConcurrent = students.stream() .collect(Collectors.groupingByConcurrent(Student::getSex, Collectors.toCollection(HashSet::new))); System.out.println(sexHashSetConcurrent); System.out.println("----------------------------------------- "); // 使用自定义收集器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("----------------------------------------- ");
// 五、partitioningBy分区 // 分区 partitioningBy /* 对满足预期的条件 进行分区 使用ArrayList 进行结果的收集 public staticCollector >> partitioningBy(Predicate super T> predicate) { return partitioningBy(predicate, toList()); }*/ /* 对满足预期的条件 进行分区 使用自定义收集器downstream 进行结果的收集 public static Collector > partitioningBy(Predicate super T> predicate, Collector super T, A, D> 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("----------------------------------------- "); // 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("----------------------------------------- "); // 嵌套分区 先根据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("----------------------------------------- "); // 使用自定义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("----------------------------------------- "); } }
. ____ _ __ _ _ / / ___"_ __ _ _(_)_ __ __ _ ( ( )\___ | "_ | "_| | "_ / _` | / ___)| |_)| | | | | || (_| | ) ) ) ) " |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: 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:IdeaProjectsdesign) 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: default 2019-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)]} -----------------------------------------
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/73351.html
摘要:一收集器接口陈杨收集器接口汇聚操作的元素类型即流中元素类型汇聚操作的可变累积类型汇聚操作的结果类型接口一种可变汇聚操作将输入元素累积到可变结果容器中在处理完所有输入元素后可以选择将累积的结果转换为最终表示可选操作归约操作 一、Stream收集器 Collector接口 package com.java.design.java8.Stream; import com.java.desi...
摘要:新特性总览标签本文主要介绍的新特性,包括表达式方法引用流默认方法组合式异步编程新的时间,等等各个方面。还有对应的和类型的函数连接字符串广义的归约汇总起始值,映射方法,二元结合二元结合。使用并行流时要注意避免共享可变状态。 Java8新特性总览 标签: java [TOC] 本文主要介绍 Java 8 的新特性,包括 Lambda 表达式、方法引用、流(Stream API)、默认方...
摘要:一流转换为数组集合陈杨将流转换为数组将流转换为数组将流转换为集合将流转换为集合解析 一、流 转换为数组、集合 package com.java.design.java8.Stream; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.boot.test.context...
阅读 3580·2021-11-24 10:25
阅读 2454·2021-11-24 09:38
阅读 1191·2021-09-08 10:41
阅读 2888·2021-09-01 10:42
阅读 2517·2021-07-25 21:37
阅读 1954·2019-08-30 15:56
阅读 875·2019-08-30 15:55
阅读 2705·2019-08-30 15:54