Java8的Stream流(一) --- 基礎用法

Java8中的Stream

Stream使用一種類似用SQL語句從資料庫查詢數據的直觀方式來提供一種對Java集合運算和表達的高階抽象.

Stream的特性及優點:

• 無存儲. Stream不是一種數據結構,它只是某種數據源的一個視圖,數據源可以是一個數組,Java容器或I/O channel等.
• 為函數式編程而生. 對於Stream的任何修改都不會修改背後的數據源,比如對Stream執行過濾操作並不會刪除被過濾的元素,而是會產生一個不包含被過濾掉元素的新Stream
• 惰式執行: Stream上的操作不回立即執行,只有等到用戶真正需要結果的時候才會執行.
• 可消費性: Stream只能被消費一次,一旦遍歷過後就會失效,就像容器的迭代器一樣,想要再次遍歷必須重新生成.

Stream的創建

1. 通過已有的集合來創建流:

通過集合的stream方法來創建流

// 數組
String[] s = "I Love You But I miss You so I miss you".split(" ");
Stream<String> stream = Arrays.stream(s);
// 集合
List<String> list = Arrays.asList(s);
Stream<String> stream1 = list.stream();

1. 通過Stream創建流

Stream類提供了of靜態方法來創建Stream流

Stream<String> stringStream = Stream.of("1", "2", "3");

Stream流常用的中間操作

filter

filter方法用於通過設置的條件過濾出元素,下麵的例子是過濾出長度大於3的字元串

String[] s = "I Love You But I miss You so I miss you".split(" ");
List<String> list = Arrays.asList(s);
// 流轉List
list.stream().filter(str -> str.length() > 3);

map

map元素用於映射每隔元素到對應的結果,下麵的例子用map輸出元素對應的平方數

Stream.of(1,2,3,4,5).map(i -> i * i).forEach(System.out::println);

limit / skip

limit是返回Stream的前面n個元素;skip是跳過前面n個元素.下麵的例子是保留前四個元素:

Stream.of(1,2,3,4,5).limit(4).forEach(System.out::println);

sorted

sorted方法是用於對流進行排序.下麵例子是進行排序

// 預設是從小到大
Stream.of(5,4,3,2,1).sorted().forEach(System.out::println);
// 重寫比較器方法從大到小
Stream.of(1,2,3,4,5).sorted((x,y)-> {return y - x;}).forEach(System.out::println);

distinct

distinct主要用來去重,下麵的例子是用來去重的

// 去重
Stream.of(5,4,3,5,4).distinct().forEach(System.out::println);

註意上面操作的返回結果還是Stream流,這個意思也就是可以進行流式操作,直到遇到最終操作,下麵就說一下最終操作.

最終操作

最終操作就是一些輸出,統計,轉換等操作,返回結果不再是Stream流. 但是註意的是當進行最終操作之後,不可再次使用流,否則會拋出異常.

java.lang.IllegalStateException: stream has already been operated upon or closed

forEach

Stream利用forEach來迭代流中的數據,下麵的代碼片段使用forEach輸出10個隨機數

Random random = new Random();
random.ints().limit(10).forEach(System.out::println);

count

count方法是用來統計流中元素的個數

Stream.of(5,4,3,5,4).count();

collect

collect方法是一個規約操作,就是將結果進行轉換為集合或者其他. 下麵的例子是將流轉化為集合.

Stream.of(5,4,3,5,4).collect(Collectors.toList());

當然其中還有很多方法,比如說reduce(累計求和),flatMap等等方法,源碼路徑為: java.util.stream.Stream