JDK12的新特性:teeing collectors

簡介

JDK12爲java.util.stream.Collectors添加了一個新的teeing方法，怎麼翻譯呢？看到不少人都把它翻譯成「發球臺」，我不由潸然淚下，哪裏有那麼複雜，tee就是T。它的做用就像是一個T型，數據從兩頭進入，而後從一頭流出。teeing的做用也就在此。

更多內容請訪問 www.flydean.com

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

本文做者：flydean程序那些事

本文連接：http://www.flydean.com/jdk12-teeing-collectors/

本文來源：flydean的博客

歡迎關注個人公衆號:程序那些事，更多精彩等着您！