【如何讓代碼變「高級」(二)】-這樣操做值得一波666（Java Stream）（這麼有趣）

歡迎關注公衆號【 Ccww筆記】，原創技術文章第一時間推出

「致"高級"工程師(BUG工程師)
一顆折騰的心
原創不易，點個贊💗，支持支持

往期文章:

• 【如何讓代碼變「高級」(一)】-Spring組合註解提高代碼維度（這麼有趣）
• ...

開發中的代碼

在開發中的代碼是否是很常見這樣的代碼：

這樣的?

for循環取元素取值

List<User> szUserList = new ArrayList<>();
 for (User user : userList) {
   if (user.getAddress().equals("shenzhen")) {
    szUserList.add(user);
   }
 }

或者這樣的?

for循環去重

for (int i = 0; i < list.size() - 1; i++) {
            for (int j = list.size() - 1; j > i; j--) {
                if (list.get(j).equals(list.get(i))) {
                    list.remove(j);
                }
            }
        }

Set set = new HashSet();
        List<String> newList = new ArrayList();
        for (Iterator iter = list.iterator(); iter.hasNext();) {
            Object element = iter.next();
            if (set.add(element))
                newList.add(element);
        }
        list.clear();
        list.addAll(newList);
      
  }

對於普通的CV族來講,這樣就差很少了,功能實現了,又能夠收拾包袱準備下班了.完美!!!

但對於咱們"高級"CV族來,這不夠,這遠遠的不夠,咱們須要保持一顆折騰的心💗,這樣的代碼彰顯不出咱們這段位的價值(青銅😀王者).

因此咱們須要一種方式去提高咱們代碼的維度,讓咱們的代碼變得更"高級", 使代碼更加簡潔而且更加語義化 .

因爲"高級"CV"族保持這樣的心態:

平凡的人,平凡的生活,平凡的工做

該有一顆不平凡的心💗

找出一種方式能夠很好的升級這種代碼問題:

Java 8 新提供給開發者的一組操做集合的 API----Stream 流

咱們如何看待Stream流

那Stream流是如何來提高代碼維度?

首先咱們來看看Stream流處理for循環取元素取值:

List<User> szUserList=userList.stream()                             
        .filter(user-> user.getAddress().equals("shenzhen"))    
        .collect(Collectors.toList());

其實, stream流會把須要處理的元素集合看做一種流， 流在管道中傳輸， 而且能夠在管道的節點上進行處理， 好比篩選、排序、聚合等。Stream 流能夠極大的提升開發效率，也可使用它寫出更加簡潔明瞭的代碼。

那麼Stream流能夠分幾種:

• 順序流 : 按照順序對集合中的元素進行處理
• 並行流 : 使用多線程同時對集合中多個元素進行處理

在使用並行流的時候就要注意線程安全的問題

元素流在管道中通過中間操做（intermediate operation）的處理，最後由終端操做 (terminal operation) 獲得前面處理的結果。

• 中間操做(intermediate operation): 中間操做會產生另外一個流 ,( 流是一種惰性操做，全部對源數據的計算只在終止操做被初始化的時候纔會執行), 並且中間操做還分無狀態操做和有狀態操做兩種 .

  • 無狀態操做 : 在處理流中的元素時，會對當前的元素進行單獨處理。 (例如:過濾操做).
  • 有狀態操做 : 某個元素的處理可能依賴於其餘元素.( 例如:查找最小值，最大值，和排序 ).
• 終止操做 (terminal operation):消費 Stream 流，而且會產生一個結果 . 若是一個 Stream 流被消費過了，那它就不能被重用的。

Stream流通常的執行過程可歸納爲:

1. 源(Stream)
2. 零個或多箇中間操做(intermediate operation)
3. 終止操做 （到這一步纔會執行整個stream pipeline計算） (terminal operation)

源的建立方式

• 使用Collection下的 stream() 和 parallelStream() 方法
• 使用Stream中的靜態方法：of()

List< String> createStream = new ArrayList< String>();
// 順序流
Stream< String> stream = createStream.stream();
// 並行流
Stream< String> parallelStream = createStream.parallelStream();
// of()方法建立
Stream< String> stringStream = Stream.of(
    createStream.toArray(new String[createStream.size()]));

Intermediate操做

中間操做包括map (mapToInt, flatMap 等)、 filter、 distinct、 sorted、 peek、 limit、 skip、 parallel、 sequential、 unordered等.

經常使用操做解析:

• filter : 篩選符合條件的元素後從新生成一個新的流。
• map : 接收一個函數做爲參數，該函數會被應用到每一個元素上，並將其映射成一個新的元素。
• flatMap: 接收一個函數做爲參數，將流中的每一個值都換成另外一個流，而後把全部流鏈接成一個流。
• distinct: 去重操做，將 Stream 流中的元素去重後，返回一個新的流。
• sorted: 產生一個天然順序排序或者指定排序條件的新流。
• skip:跳過n元素，配合limit(n)可實現分頁
• peek: 生成一個包含原Stream的全部元素的新Stream，同時會提供一個消費函數（Consumer實例），新Stream每一個元素被消費的時候都會執行給定的消費函數(通常用於重賦值那些)；
• limit: 對一個Stream進行截斷操做，獲取其前N個元素，若是原Stream中包含的元素個數小於N，那就獲取其全部的元素；

terminal操做

終止操做包括:forEach、 forEachOrdered、 toArray、 reduce、 collect、 min、 max、 count、 anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 iterator等

經常使用操做解析:

• forEach: 遍歷了流中的元素。(終端操做)
• collect: 接收一個Collector實例，將流中元素收集成另一個數據結構
• max:得到流中最大值，比較器能夠由本身定義。(終端操做)
• min: 得到流中最小值，比較器能夠由本身定義。(終端操做)
• anyMatch : 判斷 Stream 流中是否有任何符合要求的元素，若是有則返回 ture,沒有返回 false。（終端操做）

該如何操做呢?

Stream操做均可以按照通常步驟進行.

好比上面的去重操做:

distinct操做:

list=list.stream()
           .distinct()
           .collect(Collectors.toList());

NOTE: distinct()使用 hashCode() 和 eqauls() 方法來獲取不一樣的元素。所以，須要去重的類必須實現 hashCode() 和 equals() 方法

結合filter,distinct,peek,skip,limit,collect例子:

List arrList = userList.stream().filter(user -> user.getName().equals("ccww"))//過濾
                .distinct()//去重
                .peek(user -> user.setAddress("shenzhen"))//從新賦值
                .skip(2)//跳讀
                .limit(2)//讀取2個元素
                .collect(Collectors.toList());

map的例子:

List arrList1=userList.stream()
                .map(user->{
                     //todo 處理函數
                    user.setAddress(cityService.getCity());
                }).collect(Collectors.toList());
    }

如今咱們主要了解了 Java 8 Stream 流的基礎知識及使用，涵蓋 Stream 流的分類、接口、相關 API 操做使用, 在實際開發中,必定還會有更多的應用,更多Stream詳細內容,會在接下來好好文章中..

各位看官還能夠嗎？喜歡的話，動動手指點個贊💗，點個關注唄！！謝謝支持！

也歡迎關注公衆號【Ccww筆記】，原創技術文章第一時間推出