試水jdk8 stream

jdk8出來日子不短了，jdk11都出來了，不過用的最多的不過是1.5罷了。

今年終於鼓起勇氣認真對待它，在18年記錄下學習stream，畫上一個圓。

先看個圖

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

說說stream吧。前提得有lambda的基礎。

Stream 是Java8 中處理集合的關鍵抽象概念，它能夠指定你但願對集合進行的操做，能夠執行很是複雜的查找、過濾和映射數據等操做。使用Stream API 對集合數據進行操做，就相似於使用SQL 執行的數據庫查詢。也可使用Stream API 來並行執行操做。簡而言之，Stream API 提供了一種高效且易於使用的處理數據的方式。

對stream的操做分爲三類。

1. 建立stream
2. 中間操做(intermediate operations)
3. 結束操做(terminal operations):

流程以下圖

建立stream

雖然大部分狀況下stream是容器調用Collection.stream()方法獲得的，但stream和collections有如下不一樣：

• 無存儲。stream不是一種數據結構，它只是某種數據源的一個視圖，數據源能夠是一個數組，Java容器或I/O channel等。
• 爲函數式編程而生。對stream的任何修改都不會修改背後的數據源，好比對stream執行過濾操做並不會刪除被過濾的元素，而是會產生一個不包含被過濾元素的新stream。
• 惰式執行。stream上的操做並不會當即執行，只有等到用戶真正須要結果的時候纔會執行。
• 可消費性。stream只能被「消費」一次，一旦遍歷過就會失效，就像容器的迭代器那樣，想要再次遍歷必須從新生成。

Stream API是Java 8中加入的一套新的API，主要用於處理集合操做，不過它的處理方式與傳統的方式不一樣，
稱爲「數據流處理」。流（Stream）相似於關係數據庫的查詢操做，是一種聲明式操做。好比要從數據庫中獲取全部id大於1(filter)的用戶的名稱(map)，
並按照用戶的score進行排序(sorted)，若是在sql中就會很容易完成，可是在java程序中，在jdk8之前可能要使用不少的if條件，可是在jdk8的stream
流中，咱們能夠這樣

@Test public void test5() { List<String> collect = list.stream() .filter(p -> p.getId() > 1) .sorted(Comparator.comparing(Star::getScore)) .map(Star::getName) .collect((Collectors.toList())); System.out.println(collect); }

 就是這麼的容易。

 

 

 

 

jdk雙冒號

仍是比較繞的，看代碼就明白了。詳細借鑑

package com.test; import java.util.Arrays; import java.util.List; import java.util.function.Consumer; import org.junit.Test; public class DoubleColonTest { public static void myPrint(String str) { System.out.println("print value : " + str); } /** * 不使用雙冒號 */ @Test public void test1() { List<String> list = Arrays.asList("劉德華","黎明","張學友","郭富城"); list.forEach(p -> myPrint(p)); } /** * 使用雙冒號 */ @Test public void test2() { List<String> list = Arrays.asList("劉德華","黎明","張學友","郭富城"); list.forEach(DoubleColonTest::myPrint); } /** * 相似於雙冒號 */ @Test public void test3() { List<String> list = Arrays.asList("劉德華","黎明","張學友","郭富城"); Consumer<String> methodParam = DoubleColonTest::myPrint; list.forEach(methodParam); } /** * 相似於雙冒號 */ @Test public void test4() { List<String> list = Arrays.asList("劉德華","黎明","張學友","郭富城"); Consumer<String> methodParam = DoubleColonTest::myPrint; list.forEach(p -> methodParam.accept(p)); } }

 

 

完整代碼實例

package com.test; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.Iterator; import java.util.List; import java.util.stream.Collectors; import java.util.stream.Stream; import org.junit.Before; import org.junit.Test; public class TestStream { List<Star> list = null; @Before public void before() { list = new ArrayList<Star>() { { add(new Star(1, "張學友", 11.3)); add(new Star(3, "劉德華", 4.3)); add(new Star(2, "黎明", 13.3)); add(new Star(5, "郭富城", 22.3)); add(new Star(4, "范冰冰", 2.3)); } }; } /** * 遍歷方式 */ @Test public void test1() { System.out.println("第一種---------"); for (Star Star : list) { System.out.println(Star); } System.out.println("第二種---------"); list.forEach(p -> System.out.println(p)); System.out.println("第三種---------"); list.forEach(System.out::println); System.out.println("第四種---------"); Iterator<Star> iterator = list.iterator(); while (iterator.hasNext()) { System.out.println(iterator.next()); } System.out.println("第五種---------"); for (int i = 0; i < list.size(); i++) { System.out.println(list.get(i)); } System.out.println("第六種---------"); for (Iterator<Star> it = list.iterator(); it.hasNext();) { System.out.println(it.next()); } System.out.println("第七種---------"); for (int i = 0; i < list.size();) { System.out.println(list.get(i)); i++; } } /** * 普通排序 */ @Test public void test2() { Collections.sort(list, new Comparator<Star>() { @Override public int compare(Star o1, Star o2) { return o1.getScore().compareTo(o2.getScore()); } }); list.forEach(p -> System.out.println(p)); } /** * lambda排序 */ @Test public void test3() { Collections.sort(list, (p1, p2) -> p1.getScore().compareTo(p2.getScore())); list.forEach(p -> System.out.println(p)); } /** * streame排序 */ @Test public void test4() { Stream<Star> stream = list.stream().sorted(Comparator.comparing(Star::getScore));// .forEach(p ->
        stream.forEach(p -> System.out.println(p)); // list.forEach(p -> System.out.println(p));
 } /** * 進行過濾操做 */ @Test public void test5() { List<String> collect = list.stream() .filter(p -> p.getId() > 1) .sorted(Comparator.comparing(p -> p.getScore())) // .sorted(Comparator.comparing(Star::getScore))
 .map(Star::getName) .collect((Collectors.toList())); System.out.println(collect); } } class Star { private Integer id; private String name; private Double score; public Double getScore() { return score; } public void setScore(Double score) { this.score = score; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Star() { super(); } public Star(Integer id, String name, Double score) { super(); this.id = id; this.name = name; this.score = score; } @Override public String toString() { return "Star [id=" + id + ", name=" + name + ", score=" + score + "]"; } }

 

OK，到位，入個門。。。

 

借鑑的地址

http://www.nowcode.cn/index.php/2017/02/27/326/

https://www.jianshu.com/p/ceb7bf515c03