摘要:一自定义收集器陈杨将集合转换为集合存放相同元素二自定义收集器陈杨将学生对象按照存放从中间容器数据类型转换为结果类型数据类型一致若不一致抛出类型转换异常对中间容器数据结果类型进行强制类型转换多个线程同时操作同一个容器并行多线
一、自定义SetCustomCollector收集器
package com.java.design.Stream.CustomCollector; import java.util.*; import java.util.function.BiConsumer; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.function.Supplier; import java.util.stream.Collector; /** * @author 陈杨 */ // 将List集合转换为Set集合 存放相同元素 public class SetCustomCollector二、自定义StudentCustomCollector收集器implements Collector , Set > { @Override public Supplier > supplier() { System.out.println("supplier invoked!"); // return TreeSet::new; return HashSet::new; } @Override public BiConsumer , T> accumulator() { System.out.println("accumulator invoked!"); return Set ::add; } @Override public BinaryOperator > combiner() { System.out.println("combiner invoked!"); return (first, last) -> { first.addAll(last); return first; }; } @Override public Function , Set > finisher() { System.out.println("finisher invoked!"); return Function.identity(); } @Override public Set characteristics() { System.out.println("characteristics invoked!"); return Collections.unmodifiableSet(EnumSet.of (Characteristics.IDENTITY_FINISH, Characteristics.UNORDERED)); // return Collections.unmodifiableSet(EnumSet.of(Characteristics.UNORDERED)); } }
package com.java.design.Stream.CustomCollector; import com.java.design.java8.entity.Student; import java.util.*; import java.util.function.BiConsumer; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.function.Supplier; import java.util.stream.Collector; /** * @author 陈杨 */ // 将学生对象 按照HashMap三、SetCustomCollectorTest测试存放 sid student public class StudentCustomCollector implements Collector , Map > { @Override public Supplier > supplier() { System.out.println("supplier invoked!"); return ArrayList::new; } @Override public BiConsumer
, Student> accumulator() { System.out.println("accumulator invoked!"); return (list, student) -> { System.out.println("accumulator:" + Thread.currentThread().getName()); list.add(student); }; } @Override public BinaryOperator
> combiner() { System.out.println("combiner invoked!"); return (first, last) -> { first.addAll(last); return first; }; } @Override public Function
, Map
> finisher() { System.out.println("finisher invoked!"); return list -> { Map map = new HashMap<>(); list.forEach(student -> map.put(student.getId(), student)); return map; }; } @Override public Set characteristics() { System.out.println("Characteristics invoked!"); return Collections.unmodifiableSet(EnumSet.of(Characteristics.CONCURRENT)); } // Characteristics.IDENTITY_FINISH 从中间容器数据类型 转换为 结果类型 数据类型一致 // 若不一致 抛出类型转换异常 finisher对中间容器数据-->结果类型 进行强制类型转换 // Characteristics.CONCURRENT 多个线程同时操作同一个容器 --> 并行 // Indicates that this collector is concurrent, meaning that // the result container can support the accumulator function being // called concurrently with the same result container from multiple threads. // parallelStream (多线程)并行流 操作 多个结果容器 --> 执行combiner // Characteristics.CONCURRENT + parallelStream 结果容器只有1个 ---> 不执行 combiner // ConcurrentModificationException 并发修改异常 // 注意:并行情况下 累加器对结果容器执行单一操作 // 不要在累加器返回的函数式接口实例中做额外的操作 // 不能打印集合类容 同时向集合里添加新元素 // This exception may be thrown by methods that have detected concurrent // modification of an object when such modification is not permissible }
package com.java.design.java8.Stream.CustomCollector; import com.java.design.Stream.CustomCollector.SetCustomCollector; import com.java.design.java8.entity.Student; import com.java.design.java8.entity.Students; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; import java.util.List; import java.util.Set; /** * @author 陈杨 */ @SpringBootTest @RunWith(SpringRunner.class) public class SetCustomCollectorTest { private List四、StudentCustomCollectorTest测试students; @Before public void init() { students = new Students().init(); } @Test public void testSetCustomCollector() { Set set = students.stream().collect(new SetCustomCollector<>()); System.out.println(set); } /*public static TerminalOp makeRef(Collector super T, I, ?> collector) { Supplier supplier = Objects.requireNonNull(collector).supplier(); BiConsumer accumulator = collector.accumulator(); BinaryOperator combiner = collector.combiner(); class ReducingSink extends Box implements AccumulatingSink { @Override public void begin(long size) { state = supplier.get(); } @Override public void accept(T t) { accumulator.accept(state, t); } @Override public void combine(ReducingSink other) { state = combiner.apply(state, other.state); } } return new ReduceOp (StreamShape.REFERENCE) { @Override public ReducingSink makeSink() { return new ReducingSink(); } @Override public int getOpFlags() { return collector.characteristics().contains(Collector.Characteristics.UNORDERED) ? StreamOpFlag.NOT_ORDERED : 0; } }; }*/ /*public final R collect(Collector super P_OUT, A, R> collector) { A container; if (isParallel() && (collector.characteristics().contains(Collector.Characteristics.CONCURRENT)) && (!isOrdered() || collector.characteristics().contains(Collector.Characteristics.UNORDERED))) { container = collector.supplier().get(); BiConsumer accumulator = collector.accumulator(); forEach(u -> accumulator.accept(container, u)); } else { container = evaluate(ReduceOps.makeRef(collector)); } return collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH) ? (R) container : collector.finisher().apply(container); }*/ // 执行流程 方法调用顺序 // container = evaluate(ReduceOps.makeRef(collector)); // Supplier supplier = Objects.requireNonNull(collector).supplier(); // BiConsumer accumulator = collector.accumulator(); // BinaryOperator combiner = collector.combiner(); // return collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)是否有序 // return collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)是否包含IDENTITY_FINISH // ? (R) container 注意强制类型转换 (中间类型 与 返回结果类型) // 注意强制类型转换 /*CollectorImpl(Supplier supplier, BiConsumer accumulator, BinaryOperator combiner, Set characteristics) { this(supplier, accumulator, combiner, castingIdentity(), characteristics); } @SuppressWarnings("unchecked") private static Function castingIdentity() { return i -> (R) i; }*/ // EnumSet.of(Characteristics.IDENTITY_FINISH, Characteristics.UNORDERED) // 包含 IDENTITY_FINISH 打印结果 // supplier invoked! // accumulator invoked! // combiner invoked! // characteristics invoked! // characteristics invoked! // Set 集合对象 // EnumSet.of(Characteristics.UNORDERED) // 不包含 IDENTITY_FINISH 打印结果 // supplier invoked! // accumulator invoked! // combiner invoked! // characteristics invoked! // characteristics invoked! // finisher invoked! // Set 集合对象 }
package com.java.design.java8.Stream.CustomCollector; import com.java.design.Stream.CustomCollector.StudentCustomCollector; import com.java.design.java8.entity.Student; import com.java.design.java8.entity.Students; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; import java.util.List; import java.util.Map; /** * @author 陈杨 */ @SpringBootTest @RunWith(SpringRunner.class) public class StudentCustomCollectorTest { private List五、测试结果students; @Before public void init() { students = new Students().init(); } @Test public void testStudentCustomCollectorTest() { System.out.println("单线程"); Map sequentialMap = students.stream().collect(new StudentCustomCollector()); System.out.println("串行流执行效果: --------------------------------------- "+sequentialMap); System.out.println("--------------------------------------- "); System.out.println("多线程"); Map parallelMap = students.parallelStream().collect(new StudentCustomCollector()); System.out.println("并行流执行效果: --------------------------------------- "+parallelMap); System.out.println("--------------------------------------- "); } }
SetCustomCollectorTest测试结果 . ____ _ __ _ _ / / ___"_ __ _ _(_)_ __ __ _ ( ( )\___ | "_ | "_| | "_ / _` | / ___)| |_)| | | | | || (_| | ) ) ) ) " |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.1.2.RELEASE) 2019-02-20 17:14:45.547 INFO 3260 --- [ main] c.j.d.j.S.C.SetCustomCollectorTest : Starting SetCustomCollectorTest on DESKTOP-87RMBG4 with PID 3260 (started by 46250 in E:IdeaProjectsdesign) 2019-02-20 17:14:45.548 INFO 3260 --- [ main] c.j.d.j.S.C.SetCustomCollectorTest : No active profile set, falling back to default profiles: default 2019-02-20 17:14:46.055 INFO 3260 --- [ main] c.j.d.j.S.C.SetCustomCollectorTest : Started SetCustomCollectorTest in 0.686 seconds (JVM running for 1.43) supplier invoked! accumulator invoked! combiner invoked! characteristics invoked! characteristics invoked! [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), Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8)]
StudentCustomCollectorTest测试 . ____ _ __ _ _ / / ___"_ __ _ _(_)_ __ __ _ ( ( )\___ | "_ | "_| | "_ / _` | / ___)| |_)| | | | | || (_| | ) ) ) ) " |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v2.1.2.RELEASE) 2019-02-20 17:15:52.817 INFO 3292 --- [ main] c.j.d.j.S.C.StudentCustomCollectorTest : Starting StudentCustomCollectorTest on DESKTOP-87RMBG4 with PID 3292 (started by 46250 in E:IdeaProjectsdesign) 2019-02-20 17:15:52.818 INFO 3292 --- [ main] c.j.d.j.S.C.StudentCustomCollectorTest : No active profile set, falling back to default profiles: default 2019-02-20 17:15:53.354 INFO 3292 --- [ main] c.j.d.j.S.C.StudentCustomCollectorTest : Started StudentCustomCollectorTest in 0.745 seconds (JVM running for 1.439) 单线程 supplier invoked! accumulator invoked! combiner invoked! Characteristics invoked! accumulator:main accumulator:main accumulator:main accumulator:main accumulator:main Characteristics invoked! finisher invoked! 串行流执行效果: --------------------------------------- {1=Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8), 2=Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8), 3=Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), 4=Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), 5=Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)} --------------------------------------- 多线程 Characteristics invoked! Characteristics invoked! supplier invoked! accumulator invoked! combiner invoked! Characteristics invoked! accumulator:main accumulator:ForkJoinPool.commonPool-worker-5 accumulator:ForkJoinPool.commonPool-worker-5 accumulator:ForkJoinPool.commonPool-worker-3 accumulator:main Characteristics invoked! finisher invoked! 并行流执行效果: --------------------------------------- {1=Student(id=1, name=Kirito, sex=Male, age=18, addr=Sword Art Online, salary=9.99999999E8), 2=Student(id=2, name=Asuna, sex=Female, age=17, addr=Sword Art Online, salary=9.99999999E8), 3=Student(id=3, name=Sinon, sex=Female, age=16, addr=Gun Gale Online, salary=9.99999999E8), 4=Student(id=4, name=Yuuki, sex=Female, age=15, addr=Alfheim Online, salary=9.99999999E8), 5=Student(id=5, name=Alice, sex=Female, age=14, addr=Alicization, salary=9.99999999E8)} ---------------------------------------
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/73347.html
摘要:陈杨一静态工厂类实现方式一静态工厂类实现方式静态工厂类最终由实现通过实现通过实现底层由实现是的一种具化表现形式使用拼接字符串二静态工厂类常用收集器二静态工厂类常用收集器返回一个不可修改的按照相遇的顺序返回一个不可修改的无序返回 /** * @author 陈杨 */ @SpringBootTest @RunWith(SpringRunner.class) public class...
摘要:一收集器接口陈杨收集器接口汇聚操作的元素类型即流中元素类型汇聚操作的可变累积类型汇聚操作的结果类型接口一种可变汇聚操作将输入元素累积到可变结果容器中在处理完所有输入元素后可以选择将累积的结果转换为最终表示可选操作归约操作 一、Stream收集器 Collector接口 package com.java.design.java8.Stream; import com.java.desi...
摘要:陈杨一流的定义流支持串行并行聚合操作元素序列二流的创建流的创建以方法生成流三 package com.java.design.java8.Stream.StreamDetail; import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; import org.springframe...
摘要:陈杨一流的创建源集合一流的创建源集合集合默认方法接口与静态类实现接口与静态类实现二接口二接口接口对数据源中元素进行遍历或分区延迟绑定数据源绑定时机首次遍历切分查询大小而不是在创建时非延迟绑定数据源绑定时机创建时或的方法首次调用与 package com.java.design.java8.Stream.StreamDetail.BaseStreamDetail; import or...
摘要:新特性总览标签本文主要介绍的新特性,包括表达式方法引用流默认方法组合式异步编程新的时间,等等各个方面。还有对应的和类型的函数连接字符串广义的归约汇总起始值,映射方法,二元结合二元结合。使用并行流时要注意避免共享可变状态。 Java8新特性总览 标签: java [TOC] 本文主要介绍 Java 8 的新特性,包括 Lambda 表达式、方法引用、流(Stream API)、默认方...
阅读 3934·2021-11-22 13:53
阅读 1648·2021-08-25 09:39
阅读 2390·2019-08-29 18:36
阅读 1448·2019-08-26 13:35
阅读 1193·2019-08-26 11:57
阅读 1663·2019-08-23 15:57
阅读 775·2019-08-23 14:55
阅读 1110·2019-08-23 14:51