“致"高級"工程師(BUG工程師)

一顆折騰的心

原創不易，點個贊💗，支持支持

開發中的代碼

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

這樣的?

for循環取元素取值

List 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 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 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操作

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筆記】，原創技術文章第一時間推出

image

總結

以上是生活随笔為你收集整理的java怎么让1的数据2可以拥有,【如何让代码变“高级”(二)】-这样操作值得一波666（Java Stream）（这么有趣）...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。