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