摘要：內(nèi)部迭代與使用迭代器顯式迭代的集合不同，流的迭代操作是在背后進行的。流只能遍歷一次請注意，和迭代器類似，流只能遍歷一次。

流是Java API的新成員，它允許你以聲明性方式處理數(shù)據(jù)集合（通過查詢語句來表達(dá)，而不是臨時編寫一個實現(xiàn)）。就現(xiàn)在來說，你可以把它們看成遍歷數(shù)據(jù)集的高級迭代器。此外，流還可以透明地并行處理，你無需寫任何多線程代碼了！我會在后面的筆記中詳細(xì)記錄和解釋流和并行化是怎么工作的。我們簡單看看使用流的好處吧。下面兩段代碼都是用來返回低熱量的菜肴名稱的，并按照卡路里排序，一個是用Java7寫的，另一個是用Java8的流寫的。比較一下。不用太擔(dān)心Java 8代碼怎么寫，我們在接下來會對它進行詳細(xì)的了解。

使用Java7：

private static List getLowCaloricDishesNamesInJava7(List dishes) {
    List lowCaloricDishes = new ArrayList<>();
    // 遍歷篩選出低于400卡路里的菜，添加到另外一個集合中
    for (Dish d : dishes) {
        if (d.getCalories() < 400) {
            lowCaloricDishes.add(d);
        }
    }

    // 對集合按照卡路里大小進行排序
    List lowCaloricDishesName = new ArrayList<>();
    Collections.sort(lowCaloricDishes, new Comparator() {
        @Override
        public int compare(Dish d1, Dish d2) {
            return Integer.compare(d1.getCalories(), d2.getCalories());
        }
    });

    // 遍歷將菜名添加到另外一個集合中
    for (Dish d : lowCaloricDishes) {
        lowCaloricDishesName.add(d.getName());
    }
    return lowCaloricDishesName;
}

在上面的代碼中，看起來很冗長，我們使用了一個“垃圾變量”lowCaloricDishes。它唯一的作用就是作為一次性的中間容器。 在Java8，實現(xiàn)的細(xì)節(jié)被放到了它本該歸屬的庫力了。
使用Java8：

private static List getLowCaloricDishesNamesInJava8(List dishes) {
    return dishes.stream()
            // 選出400卡路里以下的菜肴
            .filter(d -> d.getCalories() < 400)
            // 按照卡路里排序
            .sorted(comparing(Dish::getCalories))
            // 提取菜名
            .map(Dish::getName)
            // 轉(zhuǎn)為集合
            .collect(toList());
}

太酷了！原本十幾行的代碼，現(xiàn)在只需要一行就可以搞定，這樣的感覺真的是太棒了！還有一個很棒的新特性，為了利用多核架構(gòu)并行執(zhí)行代碼，我們只需要將stream()改為parallelStream()即可：

private static List getLowCaloricDishesNamesInJava8(List dishes) {
    return dishes
            .parallelStream()
            // 選出400卡路里以下的菜肴
            .filter(d -> d.getCalories() < 400)
            // 按照卡路里排序
            .sorted(comparing(Dish::getCalories))
            // 提取菜名
            .map(Dish::getName)
            // 轉(zhuǎn)為集合
            .collect(toList());
}

你可能會想，在調(diào)用parallelStream方法時到底發(fā)生了什么。用了多少個線程？對性能有多大的提升？不用著急，在后面的讀書筆記中會討論這些問題?，F(xiàn)在，你可以看出，從軟件工程師的角度來看，新的方法有幾個顯而易見的好處。

代碼是以聲明性的方式寫的：說明想要完成什么（篩選熱量低的菜肴）而不是說明如何實現(xiàn)一個操作（利用循環(huán)和if條件等控制流語句）。

你可以把幾個基礎(chǔ)操作鏈接起來，來表達(dá)復(fù)雜的數(shù)據(jù)處理流水線（在 filter 后面接上

sorted 、 map 和 collect 操作），同時保持代碼清晰可讀。 filter 的結(jié)果被傳給了 sorted 方法，再傳給 map 方法，最后傳給 collect 方法。

filter、sorted、map和collect等操作是與具體線程模型無關(guān)的高層次構(gòu)件，所以它們的內(nèi)部實現(xiàn)可以是單線程的，也可能透明地充分利用你的多核架構(gòu)！在實踐中，這意味著我們用不著為了讓某些數(shù)據(jù)處理任務(wù)并行而去操心線程和鎖了，Stream API都替你做好了！

現(xiàn)在就來仔細(xì)探討一下怎么使用Stream API。我們會用流與集合做類比，做點兒鋪墊。下一
章會詳細(xì)討論可以用來表達(dá)復(fù)雜數(shù)據(jù)處理查詢的流操作。我們會談到很多模式，如篩選、切片、
查找、匹配、映射和歸約，還會提供很多測驗和練習(xí)來加深你的理解。接下來，我們會討論如何創(chuàng)建和操縱數(shù)字流，比如生成一個偶數(shù)流，或是勾股數(shù)流。最后，我們會討論如何從不同的源（比如文件）創(chuàng)建流。還會討論如何生成一個具有無窮多元素的流，這用集合肯定是搞不定。

要討論流，我們首先來談?wù)劶?，這是最容易上手的方式了。Java8中的集合支持一個新的stream方法，它會返回一個流（接口定義在 java.util.stream.Stream 里）。你在后面會看到，還有很多其他的方法可以得到流，比如利用數(shù)值范圍或從I/O資源生成流元素。

那么，流到底是什么呢？簡短的定義就是“從支持?jǐn)?shù)據(jù)處理操作的源生成的元素序列”。讓我們一步步剖析這個定義。

元素序列:就像集合一樣，流也提供了一個接口，可以訪問特定元素類型的一組有序值。因為集合是數(shù)據(jù)結(jié)構(gòu)，所以它的主要目的是以特定的時間/空間復(fù)雜度存儲和訪問元素（如ArrayList 與 LinkedList ）。但流的目的在于表達(dá)計算，比如你前面見到的filter 、 sorted 和 map 。集合講的是數(shù)據(jù)，流講的是計算。

源：流會使用一個提供數(shù)據(jù)的源，如集合、數(shù)組或輸入/輸出資源。請注意，從有序集合生成流時會保留原有的順序。由列表生成的流，其元素順序與列表一致。

數(shù)據(jù)處理操作：流的數(shù)據(jù)處理功能支持類似于數(shù)據(jù)庫的操作，以及函數(shù)式編程語言中的常用操作，如filter、map、reduce、find、match、sort等。流操作可以順序執(zhí)行，也可并行執(zhí)行。

此外，流操作有兩個重要的特點。

流水線：很多流操作本身會返回一個流，這樣多個操作就可以鏈接起來，形成一個大的流水線。

內(nèi)部迭代：與使用迭代器顯式迭代的集合不同，流的迭代操作是在背后進行的。

讓我們來看一段能夠體現(xiàn)所有這些概念的代碼：

List menu = Dish.MENU;
// 從menu獲得流
List threeHighCaloricDishNames = menu.stream()
        // 通過鏈?zhǔn)讲僮鳎Y選出高熱量的菜肴
        .filter(d -> d.getCalories() > 300)
        // 獲取菜名
        .map(Dish::getName)
        .limit(3)
        .collect(Collectors.toList());
// [pork, beef, chicken]
System.out.println(threeHighCaloricDishNames);

看起來很簡單，就算不明白也沒關(guān)系，我們來了解了解，剛剛使用到的一些方法：

filter： 接受Lambda，從流中排除某些元素。在剛剛的代碼中，通過傳遞Lambda表達(dá)式 d -> d.getCalories() > 300，選擇出熱量高于300卡路里的菜肴。

map：接受一個Lambda，將元素轉(zhuǎn)換成其他形式或提取信息。在剛剛的代碼中，通過傳遞方法引用Dish::getName，提取了每道菜的菜名。

limit：截斷流，使其元素不超過給定的數(shù)量。

collect：將流轉(zhuǎn)換為其他形式。在剛剛的代碼中，流被轉(zhuǎn)為一個List集合。

在剛剛解釋的這段代碼，與遍歷處理菜單集合的代碼有很大的不同。首先，我們使用了聲明性的方式來處理菜單數(shù)據(jù)。我們并沒有去實現(xiàn)篩選（filter）、提?。╩ap）或截斷（limit）功能，Stream庫已經(jīng)自帶了。因此，StreamAPI在決定如何優(yōu)化這條流水線時更為靈活。例如，篩選、提取和截斷操作可以一次進行，并在找到這三道菜后立即停止。

Java現(xiàn)有的集合概念和新的流概念都提供了接口，來配合代表元素型有序值的數(shù)據(jù)接口。所謂有序，就是說我們一般是按順序取用值，而不是隨機取用的。那這兩者有什么區(qū)別呢？

打個比方說，我們在看電影的時候，這些視頻就是一個流（字節(jié)流或幀流），流媒體視頻播放器只要提前下載用戶觀看位置的那幾幀就可以了，這樣不用等到流中大部分值計算出來。比如，我們在Youtube上看的視頻進度條隨便拖動到一個位置，你會發(fā)現(xiàn)它很快就開始播放了，不需要將整個視頻都加載好，而是加載了一段。如果，不按照這種方式的話，我們可以想象一下，視頻播放器可能沒有將整個流作為集合，保存所需要的內(nèi)存緩沖區(qū)——而且要是非得等到最后一幀出現(xiàn)才能開始看，那等待的時間就太長了，早就沒耐心看了。

初略地說，集合與流之間的差異就在于什么時候進行計算。集合是一個內(nèi)存中的數(shù)據(jù)結(jié)構(gòu)，它包含數(shù)據(jù)結(jié)構(gòu)中目前所有的值，集合中的每個元素都得先算出來才能添加到集合中。

相比之下，流則是在概念上固定的數(shù)據(jù)結(jié)構(gòu)，其元素則是按需計（懶加載）算的。需要多少就給多少。這是一種生產(chǎn)者與消費者的關(guān)系。從另一個角度來說，流就像是一個延遲創(chuàng)建的集合：只有在消費者要求的時候才會生成值。與之相反，集合則是急切創(chuàng)建的（就像黃牛囤貨一樣）。

請注意，和迭代器類似，流只能遍歷一次。遍歷完之后，我們就說這個流已經(jīng)被消費掉了。你可以從原始數(shù)據(jù)源那里再獲得一個新的流來重新遍歷一遍，就像迭代器一樣（這里假設(shè)它是集合之類的可重復(fù)的源，如果是I/O通道就沒戲了）。例如以下代碼會拋出一個異常，說流已被消費掉了：

List names = Arrays.asList("Java8", "Lambdas", "In", "Action");
Stream s = names.stream();
s.forEach(System.out::println);
// 再繼續(xù)執(zhí)行一次，則會拋出異常
s.forEach(System.out::println);

千萬要記住，它只能消費一次！

使用Collection接口需要用用戶去做迭代（比如用for-each），這個稱為外部迭代。反之，Stream庫使用內(nèi)部迭代，它幫你把迭代做了，還把得到的流值存在了某個地方，你只要給出一個函數(shù)說要干什么就可以了。下面的代碼說明了這種區(qū)別。

集合：使用for-each循環(huán)外部迭代：

// 集合：使用for-each循環(huán)外部迭代
List menu = Dish.MENU;
List names = new ArrayList<>();
for (Dish dish : menu) {
    names.add(dish.getName());
}

請注意， for-each 還隱藏了迭代中的一些復(fù)雜性。for-each結(jié)構(gòu)是一個語法糖，它背后的東西用Iterator對象表達(dá)出來更要丑陋得多。

集合：用背后的迭代器做外部迭代

List names = new ArrayList<>();
Iterator iterator = menu.iterator();
while(iterator.hasNext()) {
    Dish d = iterator.next();
    names.add(d.getName());
}

流：內(nèi)部迭代

List names = menu.stream()
                    .map(Dish::getName)
                    .collect(toList());

讓我們用一個比喻來解釋一下內(nèi)部迭代的差異和好處吧！比方說你在和你兩歲的兒子說話，希望他能把玩家收起來。

你：“兒子，我們把玩家收起來吧。地上還有玩具嗎？”
兒子：“有，球?！?你：“好，放進盒子里。還有嗎？”
兒子：“有，那是我的飛機。”
你：“好，放進盒子里。還有嗎？”
兒子：“有，我的書?！?你：“好，放進盒子里。還有嗎？”
兒子：“沒了，沒有了?！?你：“好，我們收好啦！”

這正是你每天都要對Java集合做的。你外部迭代一個集合，顯式地取出每個項目再加以處理。如果，你對兒子說“把地上的所有玩具都放進盒子里收起來”就好了。內(nèi)部迭代比較好的原因有二：第一，兒子可以選擇一只手拿飛機，另一只手拿球第二，他可以決定先拿離盒子最近的那個東西，然后再拿別的。同樣的道理，內(nèi)部迭代時，項目可以透明地并行處理，或者用更優(yōu)化的順序進行處理。要是用Java過去的那種外部迭代方法，這些優(yōu)化都是很困難的。這似乎有點兒雞蛋里挑骨頭，但這差不多就是Java 8引入流的理由了，Stream庫的內(nèi)部迭代可以自動選擇一種適合你硬件的數(shù)據(jù)表示和并行實現(xiàn)。與此相反，一旦通過寫 for-each 而選擇了外部迭代，那你基本上就要自己管理所有的并行問題了（自己管理實際上意味著“某個良辰吉日我們會把它并行化”或“開始了關(guān)于任務(wù)和 synchronized 的漫長而艱苦的斗爭”）。Java8需要一個類似于Collection 卻沒有迭代器的接口，于是就有了Stream！下面的圖說明了流（內(nèi)部迭代）與集合（外部迭代）之間的差異。

我們已經(jīng)了解過了集合與流在概念上的差異，特別是利用內(nèi)部迭代：替你把迭代做了。但是，只有你已經(jīng)預(yù)先定義好了能夠隱藏迭代的操作集合。例如filter或map，這個才有用。大多數(shù)這類操作都接受Lambda表達(dá)式作為參數(shù)，因此我們可以用前面所了解的知識來參數(shù)化其行為。

java.util.stream.Stream 中的 Stream 接口定義了許多操作。它們可以分為兩大類。我們再來看一下前面的例子：

List names = menu.stream()
                // 中間操作
                .filter(d -> d.getCalories() > 300)
                // 中間操作
                .map(Dish::getName)
                // 中間操作
                .limit(3)
                // 將Stream轉(zhuǎn)為List
                .collect(toList());

filter、map和limit可以連成一條線，collect觸發(fā)流水線執(zhí)行并關(guān)閉它?？梢赃B起來的稱為中間操作，關(guān)閉流的操作可以稱為終端操作。

諸如filter和sorted等中間操作會返回一個流。讓多個操作可以連接起來形成一個查詢。重要的是，除非流水線上觸發(fā)一個終端操作，否則中間操作不會執(zhí)行任何處理它們懶得很。這就是因為中間操作一般都可以合并起來，在終端操作時一次性全部處理。

為了搞清楚流水線到底發(fā)生了什么，我們把代碼改一改，讓每個Lambda都打印出當(dāng)前處理的菜肴（就像很多演示和調(diào)試技巧一樣，這種編程風(fēng)格要是擱在生產(chǎn)代碼里那就嚇?biāo)廊肆?，但是學(xué)習(xí)的時候卻可以直接看清楚求值的順序）：

List  names = menu.stream()
        .filter(d -> {
            System.out.println("filtering:" + d.getName());
            return d.getCalories() > 300;
        })
        .map(dish -> {
            System.out.println("mapping:" + dish.getName());
            return dish.getName();
        })
        .limit(3)
        .collect(toList());
System.out.println(names);

執(zhí)行結(jié)果：

filtering:pork
mapping:pork
filtering:beef
mapping:beef
filtering:chicken
mapping:chicken
[pork, beef, chicken]

從上面的打印結(jié)果，我們可以發(fā)現(xiàn)有好幾種優(yōu)化利用了流的延遲性質(zhì)。第一，盡管有很多熱量都高于300卡路里，但是只會選擇前三個！因為limit操作和一種稱為短路的技巧，第二，盡管filter和map是兩個獨立的操作，但是它們合并到同一次便利中了（我們把這種技術(shù)叫做循環(huán)合并）。

終端操作會從流的流水線生產(chǎn)結(jié)果。其結(jié)果是任何不是流的值，比如List、Integer，甚至是void。例如，在下面的流水線中，foreachh返回的是一個void的終端操作，它對源中的每道菜應(yīng)用一個Lambda。把System.out.println()傳遞給foreach，并要求它打印出由menu生成的流中每一個Dish：

menu.stream().forEach(System.out::println);

為了檢驗一下對終端操作已經(jīng)中間操作的理解，下面我們一起來看看一個例子：

下面哪些是中間操作哪些是終端操作？

long count = menu.stream()
            .filter(d -> d.getCalories() > 300)
            .distinct()
            .limit(3)
            .count();

答案：流水線中最后一個操作是count，它會返回一個long，這是一個非Stream的值。因此，它是終端操作。

總而言之，流的使用一般包括三件事：

一個數(shù)據(jù)源（比如集合）來執(zhí)行查詢

一個中間操作鏈，形成一條流的流水線

一個終端操作，執(zhí)行流水線，并能生成結(jié)果。

流的流水線背后的理念類似于構(gòu)建器模式。 在構(gòu)建器模式中有一個調(diào)用鏈用來設(shè)置一套配置（對流來說這就是一個中間操作鏈），接著是調(diào)用built方法（對流來說就是終端操作）。其實，我們目前所看的Stream的例子用到的方法并不是它的全部，還有一些其他的一些操作。

在本章中，我們所接觸到的一些中間操作與終端操作：

中間：

終端：

Stream是一個非常好用的一個新特性，它能幫助我們簡化很多冗長的代碼，提高我們代碼的可讀性。

流是“從支持?jǐn)?shù)據(jù)處理操作的源生成的一系列元素”。

流利用內(nèi)部迭代：迭代通過filter、map、sorted等操作被抽象掉了。

流操作有兩類：中間操作和終端操作。

filter和map等中間操作會返回一個流，并可以鏈接在一起。可以用它們來設(shè)置一條流水線，但并不會生成任何結(jié)果。

forEach和count等終端操作會返回一個非流的值，并處理流水線以返回結(jié)果。

6.流中的元素是按需計算（懶加載）的。

Github： chap4

Gitee： chap4

如果，你對Java8中的新特性很感興趣，你可以關(guān)注我的公眾號或者當(dāng)前的技術(shù)社區(qū)的賬號，利用空閑的時間看看我的筆記，非常感謝！