JDK12的新特性之teeing collectors

简介

JDK12为java.util.stream.Collectors添加了一个新的teeing方法，怎么翻译呢？看到很多人都把它翻译成“发球台”，我不禁潸然泪下，哪里有那么复杂，tee就是T。它的作用就像是一个T型，数据从两头进入，然后从一头流出。teeing的作用也就在此。

talk is cheap, show me the code

我最喜欢的就是一言不合上代码，文字的描述总是让人有点摸不着头脑，程序员还是要用程序说话。有了程序就有了逻辑，有了逻辑一切都有了。

各大网站上的例子都喜欢举maxBy和minBy的例子，我这里偏不，下面举一个统计学生平均分数和总分数的例子，希望大家能够喜欢：

@Test
  public void useTeeing(){
    List<Student> studentList= Arrays.asList(
        new Student("alice", 90),
        new Student("boy", 20),
        new Student("bruce", 40),
        new Student("batman", 100)
    );
    String teeingResult=studentList.stream().collect(
        Collectors.teeing(
            Collectors.averagingInt(Student::getScore),
            Collectors.summingInt(Student::getScore),
            (s1,s2)-> s1+ ":"+ s2
        )
    );
    log.info(teeingResult);
  }

好了，代码来了，上面我构建了一个Student的List。然后通过Collectors.teeing操作，传入了averagingInt和summingInt，最后通过一个merge表达式生成了最后的字符串。

我们看下输出结果：

[main] INFO com.flydean.TeeingCollector - 62.5:250

Teeing方法深度剖析

作为一个有追求的程序员，不深入了解下T的本质，肯定是睡不着的。我们看下T的定义：

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)

首先分析一下T方法的返回值，T返回一个Collector。Collector是一个Reduction operations。它将输入的元素经过累计之后转换成为一个结果集合。

我们再看一下Collector接口的定义：

public interface Collector<T, A, R>

Collector定义了三个参数类型，T是输入元素的类型，A是reduction operation的累加类型也就是Supplier的初始类型，R是最终的返回类型。 我们画个图来看一下这些类型之间的转换关系：

Stream中的A和Supplier中的A经过accumulator和combiner，最终在finisher中转换成R。

T方法需要传入两个downstream，这两个downstream是两个Collector，可以看到两者的返回类型是可以不同的。

最后一个merger将R1和R2两种类型转换成了最终的返回类型R。

Characteristics

最后讲一下Characteristics，Characteristics是指Collector的特征。

Characteristics是为了更好的执行collector的reduce操作。

比如，如果Characteristics是UNORDERED，则表示Collector在处理过程中并不保存元素的顺序，是没有顺序的。

如果Characteristics是CONCURRENT，则表示Collector会处理多线程的问题，而不需要Stream API来考虑。

因为T方法的前面两个参数是Collector，并且最后也返回一个Collector。

那么如果downstream1和downstream2都是UNORDERED，T最后返回的Collector也是UNORDERED的。

如果downstream1和downstream2都是CONCURRENT，T最后返回的Collector也是CONCURRENT的。

总结

上面就是T的所有介绍了。

本文的例子https://github.com/ddean2009/learn-java-base-9-to-20

到此这篇关于JDK12的新特性之teeing collectors的文章就介绍到这了,更多相关jdk新特征teeing collectors内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • JDK12的新特性之CompactNumberFormat详解

    简介 JDK12引入了新的格式化数字的类叫做CompactNumberFormat.主要方便我们对很长的数字进行简写.比如1000可以简写为1K或者1 thousand. 本文将会讲解CompactNumberFormat的基本构成和使用方法,最后在实际的例子中结束文章的讲解. 更多内容请访问www.flydean.com CompactNumberFormat详解 CompactNumberFormat做为格式化数字的一部分是NumberFormat的子类.作用就是将数字进行格式化.要想构建一

  • 浅析JDK12的五大重要新特性(推荐)

    JDK12的五大重要新特性 Java12在March 19, 2019发布了. 在2017年发布Java 9之后,Java平台发布节奏已从每3年以上的主要版本转变为每6个月发布一次功能.现在,每年的3月和9月都会发布新的版本功能. 从而提供了更细化,更快和可管理的版本更新. 这是一个好消息,不好的就是大家会觉得JDK的版本更新太快了. 什么?JDK12已经出来了? 什么?9月份要出JDK13了? 什么?我还在用JDK8? 废话少说,我们来看下JDK12的五个比较重要的新特性: 引入JVM常量AP

  • Java中JDK14的新特性之JFR,JMC和JFR事件流(推荐)

    简介 Java Flight Recorder(JFR)是JVM的诊断和性能分析工具.它可以收集有关JVM以及在其上运行的Java应用程序的数据.JFR是集成到JVM中的,所以JFR对JVM的性能影响非常小,我们可以放心的使用它. 一般来说,在使用默认配置的时候,性能影响要小于1%. JFR的历史很久远了.早在Oracle2008年收购BEA的时候就有了.JFR一般和JMC(Java Mission Control)协同工作. JFR是一个基于事件的低开销的分析引擎,具有高性能的后端,可以以二进

  • 在windows环境下安装jdk8、jdk9、jdk11、jdk12并自由切换

    在windows环境下安装jdk8.jdk9.jdk11.jdk12并自由切换在windows下安装jdk的各个版本安装各个版本的jdk,并设置安装路径配置环境各个版本的环境变量设置JAVA_HOME设置path切换jdk版本 在windows下安装jdk的各个版本安装各个版本的jdk,并设置安装路径 jdk8安装在C:\ProgramFile\Java jdk11安装在C:\ProgramFile\Java jdk12安装在C:\ProgramFile\Java jdk9安装在C:\Java9

  • JDK14性能管理工具之Jconsole的使用详解

    我们在开发java项目的时候,或多或少都会去用到Java的性能管理工具.有时候是为了提升应用程序的性能,有时候是为了查找java应用程序的bug. 性能监控和调试工具在英文中叫做profile tool,提起这种工具大家可能会想到一些非常出名的jprofile等收费工具,其实JDK也自带了一些性能调试工具,比如JMC和Jconsole. JMC现在已经和JDK的版本独立出来了,详情请参考我之前的文章: JDK 14的新特性:JFR,JMC和JFR事件流 ,今天我们将会重点讲解Jconsole的使

  • JDK14性能管理工具之jstack使用介绍

    在之前的文章中,我们介绍了JDK14中jstat工具的使用,本文我们再深入探讨一下jstack工具的使用. jstack工具主要用来打印java堆栈信息,主要是java的class名字,方法名,字节码索引,行数等信息. jstack的命令格式 Usage: jstack [-l][-e] <pid> (to connect to running process) Options: -l long listing. Prints additional information about lock

  • JDK12的新特性之teeing collectors

    简介 JDK12为java.util.stream.Collectors添加了一个新的teeing方法,怎么翻译呢?看到很多人都把它翻译成"发球台",我不禁潸然泪下,哪里有那么复杂,tee就是T.它的作用就像是一个T型,数据从两头进入,然后从一头流出.teeing的作用也就在此. talk is cheap, show me the code 我最喜欢的就是一言不合上代码,文字的描述总是让人有点摸不着头脑,程序员还是要用程序说话.有了程序就有了逻辑,有了逻辑一切都有了. 各大网站上的例

  • Java8新特性Stream流实例详解

    什么是Stream流? Stream流是数据渠道,用于操作数据源(集合.数组等)所生成的元素序列. Stream的优点:声明性,可复合,可并行.这三个特性使得stream操作更简洁,更灵活,更高效. Stream的操作有两个特点:可以多个操作链接起来运行,内部迭代. Stream可分为并行流与串行流,Stream API 可以声明性地通过 parallel() 与sequential() 在并行流与顺序流之间进行切换.串行流就不必再细说了,并行流主要是为了为了适应目前多核机器的时代,提高系统CP

  • Java 8 新特性终极版指南详解

    前言: Java 8已经公布有一段时间了,种种迹象表明Java 8是一个有重大改变的发行版.在Java Code Geeks上已经有很多介绍Java 8新特性的文章,例如Playing with Java 8 – Lambdas and Concurrency.Java 8 Date Time API Tutorial : LocalDateTime和Abstract Class Versus Interface in the JDK 8 Era.本文还参考了一些其他资料,例如:15 Must

  • Java 11 正式发布,这 8 个逆天新特性教你写出更牛逼的代码

    Java 11 正式发布,这 8 个逆天新特性教你写出更牛逼的代码

    美国时间 09 月 25 日,Oralce 正式发布了 Java 11,这是据 Java 8 以后支持的首个长期版本.非常值得大家的关注,可以通过下面的地址进行下载: https://www.oracle.com/technetwork/java/javase/downloads/jdk11-downloads-5066655.html 为什么说是长期版本,看下面的官方发布的支持路线图表. 可以看出 Java 8 扩展支持到 2025 年,而 Java 11 扩展支持到 2026 年. 现在大部

  • java8新特性将List中按指定属性排序过滤重复数据的方法

    在java中常常会遇到这样一个问题,在实际应用中,总会碰到对List排序并过滤重复的问题,如果List中放的只是简单的String类型过滤so easy,但是实际应用中并不会这么easy,往往List中放的是一个类,类中有多个属性,要过滤重复数据,而且这个重复数据要按自己指定的属性过滤,但是要想按照其它属性排序顺序过滤,所以要先排序一下,然后按照某个属性过滤. 实体类如下所示,大家只要创建下面的实体类,无需继承父类,大家不会注解式风格的话,请自行加上getter/setter方法. 首先看看gr

  • Java11 发布前抓紧掌握这些新特性

    Java11 发布前抓紧掌握这些新特性

    快速回顾 1.Lambda表达式: (参数) -> {主体} Lambda表达式打开了函数式编程爱好者继续使用Java的大门.Lambda表达式需要零个或多个参数,这些参数可以在表达式主体中访问,并随计算结果一起返回. Comparator<Integer> comparator = (a, b) -> a-b; System.out.println(comparator.compare(3, 4)); // -1 2. 函数接口:只有一种方法的接口 lambda表达式本身被视为可

  • Java8 新特性之日期时间对象及一些其他特性

    日期时间对象 关于日期时间的操作可以分为两种: 转换:与字符串的互相转换,与时间戳的互相转换 计算:计算两个时间点之间的间隔.时间点与时间段的计算(计算下周N.下个月D日.去年M月D日等等) Java8 提供了三个类:LocalDate.LocalTime.LocalDateTime,它们的形式如 2020-01-01.12:30:00.2020-01-01 12:30:00 创建对象 获取类对象的方法非常非常简单 LocalDate now = LocalDate.now(); LocalDa

  • JDK13的新特性之AppCDS详解

    简介 AppCDS的全称是Application Class-Data Sharing.主要是用来在不同的JVM中共享Class-Data信息,从而提升应用程序的启动速度. 通常来说,如果要执行class字节码,JVM需要执行下面的一些步骤:给定一个类的名字,JVM需要从磁盘上面找到这个文件,加载,并验证字节码,最后将它加载进来. 如果JVM启动的时候需要加载成百上千个class,那么需要的就不是一个小数目了. 对于打包好的jar包来说,只要jar的内容不变,那么jar包中的类的数据始终是相同的

随机推荐