開發中的代碼
在開發中的代碼是不是很常見這樣的代碼：
這樣的?
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族 VS "高級"CV族
對於“普通”的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流一般的執行過程可概括為:
-
源(Stream)
-
零個或多個中間操作(intermediate operation)
-
終止操作 （到這一步才會執行整個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筆記】，原創技術文章第一時間推出