【Java8新特性】關(guān)于Java8的Stream API，看這一篇就夠了?。?/h1>
寫在前面
Java8中有兩大最為重要的改變。第一個是 Lambda 表達式；另外一個則是 Stream API(java.util.stream.*) ，那什么是Stream API呢？Java8中的Stream又該如何使用呢？
什么是Stream?
Java8中有兩大最為重要的改變。第一個是 Lambda 表達式；另外一個則是 Stream API(java.util.stream.*)。
Stream 是 Java8 中處理集合的關(guān)鍵抽象概念，它可以指定你希望對集合進行的操作，可以執(zhí)行非常復雜的查找、過濾和映射數(shù)據(jù)等操作。使用Stream API 對集合數(shù)據(jù)進行操作，就類似于使用 SQL 執(zhí)行的數(shù)據(jù)庫查詢。也可以使用 Stream API 來并行執(zhí)行操作。簡而言之，Stream API 提供了一種高效且易于使用的處理數(shù)據(jù)的方式
流是數(shù)據(jù)渠道，用于操作數(shù)據(jù)源（集合、數(shù)組等）所生成的元素序列?！凹现v的是數(shù)據(jù)，流講的是計算！”
注意：
① Stream 自己不會存儲元素。
② Stream 不會改變源對象。相反，他們會返回一個持有結(jié)果的新Stream。
③ Stream 操作是延遲執(zhí)行的。這意味著他們會等到需要結(jié)果的時候才執(zhí)行。
Stream操作的三個步驟
創(chuàng)建 Stream
一個數(shù)據(jù)源（如：集合、數(shù)組）， 獲取一個流。
中間操作
一個中間操作鏈，對數(shù)據(jù)源的數(shù)據(jù)進行處理。
終止操作(終端操作)
一個終止操作，執(zhí)行中間操作鏈，并產(chǎn)生結(jié)果 。
如何創(chuàng)建Stream?
Java8 中的 Collection 接口被擴展，提供了兩個獲取流的方法：
1.獲取Stream
default Stream
stream() : 返回一個順序流 default Stream
parallelStream() : 返回一個并行流
2.由數(shù)組創(chuàng)建Stream
Java8 中的 Arrays 的靜態(tài)方法 stream() 可以獲取數(shù)組流：
static Stream
stream(T[] array): 返回一個流
重載形式，能夠處理對應基本類型的數(shù)組：
public static IntStream stream(int[] array)
public static LongStream stream(long[] array)
public static DoubleStream stream(double[] array)
3.由值創(chuàng)建流
可以使用靜態(tài)方法 Stream.of(), 通過顯示值創(chuàng)建一個流。它可以接收任意數(shù)量的參數(shù)。
public static Stream
of(T… values) : 返回一個流
4.由函數(shù)創(chuàng)建流
由函數(shù)創(chuàng)建流可以創(chuàng)建無限流。
可以使用靜態(tài)方法 Stream.iterate() 和Stream.generate(), 創(chuàng)建無限流 。
迭代
public static
生成
public static
Stream的中間操作
多個中間操作可以連接起來形成一個流水線，除非流水線上觸發(fā)終止操作，否則中間操作不會執(zhí)行任何的處理！而在終止操作時一次性全部處理，稱為“惰性求值”
1.篩選與切片
2.映射
3.排序
Stream 的終止操作
終端操作會從流的流水線生成結(jié)果。其結(jié)果可以是任何不是流的值，例如：List、 Integer，甚至是 void 。
1.查找與匹配
2.規(guī)約
3.收集
Collector 接口中方法的實現(xiàn)決定了如何對流執(zhí)行收集操作(如收集到 List、 Set、 Map)。但是 Collectors 實用類提供了很多靜態(tài)方法，可以方便地創(chuàng)建常見收集器實例， 具體方法與實例如下表
并行流與串行流
并行流就是把一個內(nèi)容分成多個數(shù)據(jù)塊，并用不同的線程分別處理每個數(shù)據(jù)塊的流。
Java 8 中將并行進行了優(yōu)化，我們可以很容易的對數(shù)據(jù)進行并行操作。Stream API 可以聲明性地通過 parallel() 與
sequential() 在并行流與順序流之間進行切換
Fork/Join 框架
1.簡單概述
Fork/Join 框架：就是在必要的情況下，將一個大任務，進行拆分(fork)成若干個小任務（拆到不可再拆時），再將一個個的小任務運算的結(jié)果進行 join 匯總.
2.Fork/Join 框架與傳統(tǒng)線程池的區(qū)別
采用 “工作竊取”模式（work-stealing）：
當執(zhí)行新的任務時它可以將其拆分分成更小的任務執(zhí)行，并將小任務加到線程隊列中，然后再從一個隨機線程的隊列中偷一個并把它放在自己的隊列中。
相對于一般的線程池實現(xiàn),fork/join框架的優(yōu)勢體現(xiàn)在對其中包含的任務的處理方式上.在一般的線程池中,如果一個線程正在執(zhí)行的任務由于某些原因無法繼續(xù)運行,那么該線程會處于等待狀態(tài).而在fork/join框架實現(xiàn)中,如果某個子問題由于等待另外一個子問題的完成而無法繼續(xù)運行.那么處理該子問題的線程會主動尋找其他尚未運行的子問題來執(zhí)行.這種方式減少了線程的等待時間,提高了性能。
寫在最后
最后，附上Java8新特性核心知識圖，祝大家在學習Java8新特性時少走彎路。
特別推薦一個分享架構(gòu)+算法的優(yōu)質(zhì)內(nèi)容，還沒關(guān)注的小伙伴，可以長按關(guān)注一下：
長按訂閱更多精彩▼
如有收獲，點個在看，誠摯感謝
免責聲明：本文內(nèi)容由21ic獲得授權(quán)后發(fā)布，版權(quán)歸原作者所有，本平臺僅提供信息存儲服務。文章僅代表作者個人觀點，不代表本平臺立場，如有問題，請聯(lián)系我們，謝謝！
下載文檔
