Java8中的Stream
Stream使用一種類似用SQL語句從數據庫查詢數據的直觀方式來提供一種對Java集合運算和表達的高階抽象.
Stream的特性及優點:
- 無存儲. Stream不是一種數據結構,它只是某種數據源的一個視圖,數據源可以是一個數組,Java容器或I/O channel等.
- 為函數式編程而生. 對於Stream的任何修改都不會修改背后的數據源,比如對Stream執行過濾操作並不會刪除被過濾的元素,而是會產生一個不包含被過濾掉元素的新Stream
- 惰式執行: Stream上的操作不回立即執行,只有等到用戶真正需要結果的時候才會執行.
- 可消費性: Stream只能被消費一次,一旦遍歷過后就會失效,就像容器的迭代器一樣,想要再次遍歷必須重新生成.
Stream的創建
- 通過已有的集合來創建流:
通過集合的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();
- 通過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