摘要：第四章引入流一什么是流流是的新成員，它允許你以聲明性方式處理數(shù)據(jù)集合通過(guò)查詢語(yǔ)句來(lái)表達(dá)，而不是臨時(shí)編寫(xiě)一個(gè)實(shí)現(xiàn)。
第四章 引入流
一、什么是流
流是Java API的新成員，它允許你以聲明性方式處理數(shù)據(jù)集合（通過(guò)查詢語(yǔ)句來(lái)表達(dá)，而不是臨時(shí)編寫(xiě)一個(gè)實(shí)現(xiàn)）。就現(xiàn)在來(lái)說(shuō)，你可以把它們看成遍歷數(shù)據(jù)集的高級(jí)迭代器。此外，流還可以透明地并行處理，你無(wú)需寫(xiě)任何多線程代碼。
下面兩段代碼都是用來(lái)返回低熱量的菜肴名稱的，并按照卡路里排序，一個(gè)是用Java 7寫(xiě)的，另一個(gè)是用Java 8的流寫(xiě)的。
之前（Java 7）：
List lowCaloricDishes = new ArrayList<>();
for(Dish d: menu){
if(d.getCalories() < 400){
lowCaloricDishes.add(d);
}
}
Collections.sort(lowCaloricDishes, new Comparator() {
public int compare(Dish d1, Dish d2){
return Integer.compare(d1.getCalories(), d2.getCalories());
}
});
List lowCaloricDishesName = new ArrayList<>();
for(Dish d: lowCaloricDishes){
lowCaloricDishesName.add(d.getName());
}
在這段代碼中，你用了一個(gè)“垃圾變量”lowCaloricDishes。它唯一的作用就是作為一次
性的中間容器。在Java 8中，實(shí)現(xiàn)的細(xì)節(jié)被放在它本該歸屬的庫(kù)里了。
之后（Java 8）：
import static java.util.Comparator.comparing;
import static java.util.stream.Collectors.toList;
List lowCaloricDishesName =
menu.stream()
.filter(d -> d.getCalories() < 400)
.sorted(comparing(Dish::getCalories))
.map(Dish::getName)
.collect(toList());
為了利用多核架構(gòu)并行執(zhí)行這段代碼，你只需要把stream()換成parallelStream()：
List lowCaloricDishesName =
menu.parallelStream()
.filter(d -> d.getCalories() < 400)
.sorted(comparing(Dishes::getCalories))
.map(Dish::getName)
.collect(toList());
按照Map里面的類別對(duì)菜肴進(jìn)行分組。
Map> dishesByType = menu.stream().collect(groupingBy(Dish::getType));
其他庫(kù)：Guava、Apache和lambdaj
為了給Java程序員提供更好的庫(kù)操作集合，前人已經(jīng)做過(guò)了很多嘗試。比如，Guava就是谷歌創(chuàng)建的一個(gè)很流行的庫(kù)。它提供了multimaps和multisets等額外的容器類。Apache Commons Collections庫(kù)也提供了類似的功能。Mario Fusco編寫(xiě)的lambdaj受到函數(shù)式編程的啟發(fā)，也提供了很多聲明性操作集合的工具。
流到底是什么呢？簡(jiǎn)短的定義就是“從支持?jǐn)?shù)據(jù)處理操作的源生成的元素序列”。
元素序列——就像集合一樣，流也提供了一個(gè)接口，可以訪問(wèn)特定元素類型的一組有序值。因?yàn)榧鲜菙?shù)據(jù)結(jié)構(gòu)，所以它的主要目的是以特定的時(shí)間/空間復(fù)雜度存儲(chǔ)和訪問(wèn)元素（如ArrayList 與 LinkedList）。但流的目的在于表達(dá)計(jì)算，比如你前面見(jiàn)到的filter、sorted和map。集合講的是數(shù)據(jù)，流講的是計(jì)算。我們會(huì)在后面幾節(jié)中詳細(xì)解釋這個(gè)思想。
源——流會(huì)使用一個(gè)提供數(shù)據(jù)的源，如集合、數(shù)組或輸入/輸出資源。 請(qǐng)注意，從有序集合生成流時(shí)會(huì)保留原有的順序。由列表生成的流，其元素順序與列表一致。
數(shù)據(jù)處理操作——流的數(shù)據(jù)處理功能支持類似于數(shù)據(jù)庫(kù)的操作，以及函數(shù)式編程語(yǔ)言中的常用操作，如filter、map、reduce、find、match、sort等。流操作可以順序執(zhí)行，也可并行執(zhí)行。
eg: 選出3條卡路里高于300的菜肴的菜肴的名字
import static java.util.stream.Collectors.toList;
List threeHighCaloricDishNames =
menu.stream()
.filter(d -> d.getCalories() > 300)
.map(Dish::getName)
.limit(3) //篩選（filter）、提?。╩ap）或截?cái)啵╨imit）
.collect(toList());
System.out.println(threeHighCaloricDishNames);
//在調(diào)用collect之前，沒(méi)有任何結(jié)果產(chǎn)生，實(shí)際上根本就沒(méi)有從menu里選擇元素
二、流與集合
和迭代器類似，流只能遍歷一次。遍歷完之后，我們就說(shuō)這個(gè)流已經(jīng)被消費(fèi)掉了。
使用Collection接口需要用戶去做迭代（比如用for-each），這稱為外部迭代。 相反，Streams庫(kù)使用內(nèi)部迭代——它幫你把迭代做了，還把得到的流值存在了某個(gè)地方，你只要給出一個(gè)函數(shù)說(shuō)要干什么就可以了。
三、流操作
java.util.stream.Stream中的Stream接口定義了許多操作。它們可以分為兩大類：
中間操作
可以連接起來(lái)的流操作稱為中間操作,諸如filter或sorted等
終端操作
關(guān)閉流的操作稱為終端操作,其結(jié)果是任何不是流的值，比如List、Integer，甚至void
eg:(注意循環(huán)合并）
List names =
menu.stream()
.filter(d -> {
System.out.println("filtering" + d.getName());
return d.getCalories() > 300;
})
.map(d -> {
System.out.println("mapping" + d.getName());
return d.getName();
})
.limit(3)
.collect(toList());
System.out.println(names);
此代碼執(zhí)行時(shí)將打?。?/p>
filtering pork
mapping pork
filtering beef
mapping beef
filtering chicken
mapping chicken
[pork, beef, chicken]
盡管filter和map是兩個(gè)獨(dú)立的操作，但它們合并到同一次遍歷中了（我們把這種技術(shù)叫作循環(huán)合并）。
四、使用流
流的使用一般包括三件事：
一個(gè)數(shù)據(jù)源（如集合）來(lái)執(zhí)行一個(gè)查詢；
一個(gè)中間操作鏈，形成一條流的流水線；
一個(gè)終端操作，執(zhí)行流水線，并能生成結(jié)果。
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://www.ezyhdfw.cn/yun/77531.html
