寫在前面

Java8中有兩大最為重要的改變。第一個是 Lambda 表達式；另外一個則是 Stream API(java.util.stream.*)  ，那什么是Stream API呢？Java8中的Stream又該如何使用呢？

什么是Stream?

Java8中有兩大最為重要的改變。第一個是 Lambda 表達式；另外一個則是 Stream API(java.util.stream.*)。

Stream 是 Java8 中處理集合的關(guān)鍵抽象概念，它可以指定你希望對集合進行的操作，可以執(zhí)行非常復(fù)雜的查找、過濾和映射數(shù)據(jù)等操作。使用Stream API 對集合數(shù)據(jù)進行操作，就類似于使用 SQL 執(zhí)行的數(shù)據(jù)庫查詢。也可以使用 Stream API 來并行執(zhí)行操作。簡而言之，Stream API 提供了一種高效且易于使用的處理數(shù)據(jù)的方式

流是數(shù)據(jù)渠道，用于操作數(shù)據(jù)源（集合、數(shù)組等）所生成的元素序列。“集合講的是數(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): 返回一個流

重載形式，能夠處理對應(yīng)基本類型的數(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  Stream  iterate(final T seed, final UnaryOperator f)

• 生成

public static  Stream  generate(Supplier s)

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 框架：就是在必要的情況下，將一個大任務(wù)，進行拆分(fork)成若干個小任務(wù)（拆到不可再拆時），再將一個個的小任務(wù)運算的結(jié)果進行 join 匯總.

2.Fork/Join 框架與傳統(tǒng)線程池的區(qū)別

采用 “工作竊取”模式（work-stealing）：
當(dāng)執(zhí)行新的任務(wù)時它可以將其拆分分成更小的任務(wù)執(zhí)行，并將小任務(wù)加到線程隊列中，然后再從一個隨機線程的隊列中偷一個并把它放在自己的隊列中。

相對于一般的線程池實現(xiàn),fork/join框架的優(yōu)勢體現(xiàn)在對其中包含的任務(wù)的處理方式上.在一般的線程池中,如果一個線程正在執(zhí)行的任務(wù)由于某些原因無法繼續(xù)運行,那么該線程會處于等待狀態(tài).而在fork/join框架實現(xiàn)中,如果某個子問題由于等待另外一個子問題的完成而無法繼續(xù)運行.那么處理該子問題的線程會主動尋找其他尚未運行的子問題來執(zhí)行.這種方式減少了線程的等待時間,提高了性能。

寫在最后

最后，附上Java8新特性核心知識圖，祝大家在學(xué)習(xí)Java8新特性時少走彎路。

特別推薦一個分享架構(gòu)+算法的優(yōu)質(zhì)內(nèi)容，還沒關(guān)注的小伙伴，可以長按關(guān)注一下：
長按訂閱更多精彩▼
如有收獲，點個在看，誠摯感謝