JDK12 Stream Api : teeing()

前言：

JDK 12中添加了一个新的流API收集器：Teeing()。

Collectors#teeing

简单地说，它允许使用两个独立的收集器收集流，然后使用提供的双功能合并结果。

例如，通过使用它可以计算所有流值的预期值：


// import static java.util.stream.Collectors.*;
Double ev = Stream.of(1, 2, 3, 4, 5, 6) // dice roll.collect(teeing(summingDouble(i -> i),counting(),(sum, n) -> sum / n));
System.out.println(ev); // 3.5

或者可以派生一个新的收集器，它也可以这样做：

private static Collector<Integer, ?, Double> derivingExpectedValue() {return teeing(summingDouble(i -> i),counting(),(sum, n) -> sum / n);
}

Double ev = Stream.of(1, 2, 3, 4, 5, 6).collect(derivingExpectedValue());

Teeing() 同 Collectors#groupingBy. 的使用： https://4comprehension.com/the-ultimate-guide-to-the-java-stream-api-groupingby-collector/

JDK12之前

Integer[] stream = Stream.of(1, 2, 3, 4, 5, 6).toArray(Integer[]::new);
Double ev = IntStream.range(0, stream.length).boxed().reduce(0d, (acc, i) -> acc + (((double) stream[i]) / stream.length), (acc1, acc2) -> cc1 + acc2);

或者


Integer[] stream = Stream.of(1, 2, 3, 4, 5, 6).toArray(Integer[]::new);
double ev = 0d;
for (Integer integer : stream) {ev = ev + (((double) integer) / stream.length);
}

实现机制：

public static <T, R1, R2, R> Collector<T, ?, R> teeing(Collector<? super T, ?, R1> downstream1,Collector<? super T, ?, R2> downstream2,BiFunction<? super R1, ? super R2, R> merger) {return teeing0(downstream1, downstream2, merger);
}
private static <T, A1, A2, R1, R2, R> Collector<T, ?, R> teeing0(Collector<? super T, A1, R1> downstream1,Collector<? super T, A2, R2> downstream2,BiFunction<? super R1, ? super R2, R> merger) {Objects.requireNonNull(downstream1, "downstream1");Objects.requireNonNull(downstream2, "downstream2");Objects.requireNonNull(merger, "merger");Supplier<A1> c1Supplier = Objects.requireNonNull(downstream1.supplier(), "downstream1 supplier");Supplier<A2> c2Supplier = Objects.requireNonNull(downstream2.supplier(), "downstream2 supplier");BiConsumer<A1, ? super T> c1Accumulator = Objects.requireNonNull(downstream1.accumulator(), "downstream1 accumulator");BiConsumer<A2, ? super T> c2Accumulator = Objects.requireNonNull(downstream2.accumulator(), "downstream2 accumulator");BinaryOperator<A1> c1Combiner = Objects.requireNonNull(downstream1.combiner(), "downstream1 combiner");BinaryOperator<A2> c2Combiner = Objects.requireNonNull(downstream2.combiner(), "downstream2 combiner");Function<A1, R1> c1Finisher = Objects.requireNonNull(downstream1.finisher(), "downstream1 finisher");Function<A2, R2> c2Finisher = Objects.requireNonNull(downstream2.finisher(), "downstream2 finisher");Set<Collector.Characteristics> characteristics;Set<Collector.Characteristics> c1Characteristics = downstream1.characteristics();Set<Collector.Characteristics> c2Characteristics = downstream2.characteristics();if (CH_ID.containsAll(c1Characteristics) || CH_ID.containsAll(c2Characteristics)) {characteristics = CH_NOID;} else {EnumSet<Collector.Characteristics> c = EnumSet.noneOf(Collector.Characteristics.class);c.addAll(c1Characteristics);c.retainAll(c2Characteristics);c.remove(Collector.Characteristics.IDENTITY_FINISH);characteristics = Collections.unmodifiableSet(c);}class PairBox {A1 left = c1Supplier.get();A2 right = c2Supplier.get();void add(T t) {c1Accumulator.accept(left, t);c2Accumulator.accept(right, t);}PairBox combine(PairBox other) {left = c1Combiner.apply(left, other.left);right = c2Combiner.apply(right, other.right);return this;}R get() {R1 r1 = c1Finisher.apply(left);R2 r2 = c2Finisher.apply(right);return merger.apply(r1, r2);}}return new CollectorImpl<>(PairBox::new, PairBox::add, PairBox::combine, PairBox::get, characteristics);
}

详情参考： https://bugs.openjdk.java.net/browse/JDK-8209685

JDK12 Stream Api : teeing()相关推荐

【Java8新特性】关于Java8的Stream API，看这一篇就够了！！
写在前面 Java8中有两大最为重要的改变.第一个是 Lambda 表达式:另外一个则是 Stream API(java.util.stream.*) ,那什么是Stream API呢?Java8中 ...
Java 8中Stream API的这些奇技淫巧！你都Get到了吗？
作者:我是你的小眼睛儿 https://www.jianshu.com/p/9fe8632d0bc2 Stream简介 1.Java 8引入了全新的Stream API.这里的Stream和I/O流不 ...
使用 Stream API 高逼格优化 Java 代码！
作者 | 何甜甜在吗来源 | https://juejin.cn/post/6844903945005957127 使用Stream API优化代码 Java8的新特性主要是Lambda表达式和流, ...
Java 8 中 Stream API 的奇技淫巧
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 作者 | 我是你的小眼睛儿来源 | jianshu.c ...
Java 8 Stream Api 中的 map和 flatMap 操作
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 来源 | 公众号「码农小胖哥」 1.前言 Java 8 ...
Java 8 Stream Api 中的 skip 和 limit 操作
点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 1. 前言 Java 8 Stream API 中的sk ...
java遍历栈_Java中使用StackWalker和Stream API进行堆栈遍历
1.Java 9以前堆栈遍历到目前为止,官方解决方案是获取当前线程并调用其getStackTrace()方法: StackTraceElement[] stackTraceElements = Thr ...
Atitit 实现java的linq 以及与stream api的比较
Atitit 实现java的linq 以及与stream api的比较 1.1. Linq 和stream api的关系,以及主要优缺点1 1.2. Linq 与stream api的适用场景1 1. ...
java8新特性-lambda表达式和stream API的简单使用
一.为什么使用lambda Lambda 是一个匿名函数,我们可以把 Lambda表达式理解为是一段可以传递的代码(将代码像数据一样进行传递).可以写出更简洁.更灵活的代码.作为一种更紧凑的代码风 ...

JDK12 Stream Api : teeing()

Collectors#teeing

JDK12之前

JDK12 Stream Api : teeing()相关推荐

最新文章

热门文章