Java8 Stream中間操作例項解析
這篇文章主要介紹了Java8 Stream中間操作例項解析,文中通過示例程式碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
介紹Stream
Stream 使用一種類似用於SQL 語句從資料庫查詢資料的直觀方式來提供一種對 Java 集合運算和表達的高階抽象。 Stream API可以極大提高Java程式設計師的生產力,讓程式設計師寫出高效率、乾淨、簡潔的程式碼。 這種風格將要處理的元素集合看作一種流,流在管道中傳輸,並且可以在管道的節點上進行處理,比如篩選,排序,聚合等。
Stream兩種操作
中間操作(Intermediate Operations):中間操作會返回一個新的流,一個流可以後面跟隨零個或多個intermediate操作。其目的主要是開啟流,做出某種程度的資料對映/過濾,然後會返回一個新的流,交給下一個操作使用。這類操作都是惰性化的(lazy),就是說,僅僅呼叫到這類方法,並沒有真正開始流的遍歷。而是在終端操作開始的時候才真正開始執行。
終端操作(Terminal Operations):是指返回最終的結果。一個流只能有一個terminal操作,當這個操作執行後,流就被使用“光”了,無法再被操作。所以這必定是流的最後一個操作。Terminal操作的執行,才會真正開始流的遍歷,並且會生成一個結果,或者一個 side effect。
中間操作方法分類:
- filter()
- map()
- flatMap()
- distinct()
- sorted()
- peek()
- limit()
- skip()
終端操作方法分類:
- forEach()
- forEachOrdered()
- toArray()
- reduce()
- collect()
- min()
- max()
- count()
- anyMatch()
- allMatch()
- noneMatch()
- findFirst()
- findAny()
中間操作程式碼例項詳解
1、filter(): 返回結果生成新的流中只包含滿足篩選條件的資料。
// 1、filter,返回大於2的元素集合 List<Integer> nums = Arrays.asList(1,2,3,4,5); List<Integer> result = nums.stream().filter(n -> n > 2).collect(Collectors.toList()); System.out.println(result);
執行結果:[3,5]
2、map():將流中的元素進行再次加工形成一個新流,流中的每一個元素對映為另外的元素。
// 2、map:返回元素的大寫型別和雜湊值 List<String> mzc = Arrays.asList("ma","zhi","chu"); List<String> mzcUpperCase = mzc.stream(). map(n -> n.toUpperCase()). collect(Collectors.toList()); List<Integer> mzcHashCode = mzc.stream().map(n -> n.hashCode()).collect(Collectors.toList()); System.out.println("mzcUpperCase:"+mzcUpperCase+" ----- mzcHashCode:"+mzcHashCode);
執行結果:
mzcUpperCase:[MA,ZHI,CHU] ----- mzcHashCode:[3476,120571,98480]
示例場景:取出商品的所有id,就可以這樣寫(虛擬碼):
List<Product> productList = productService.selectAll();
List<Integer> pIds = productList.stream().map(p->p.getId).collect(Collectors.toList());
這樣就可以拿到所有商品id的集合。
3、flatMap():扁平化對映,它具體的操作是將多個stream連線成一個stream,這個操作是針對類似多維陣列的,比如集合裡面包含集合,相當於降維作用。
flatMap是將流中的每個元素都放到一個流中,最後將所有的流合併成一個新流,所有流物件中的元素都合併到這個新生成的流中返回。
// flatMap:將多層集合中的元素取出來,放到一個新的集合中去 List<Integer> num1 = Arrays.asList(1,3); List<Integer> num2 = Arrays.asList(4,5,6); List<Integer> num3 = Arrays.asList(7,8,9); List<List<Integer>> lists = Arrays.asList(num1,num2,num3); Stream<Integer> outputStream = lists.stream().flatMap(l -> l.stream()); List<Integer> flatMapResult = outputStream.sorted().collect(Collectors.toList()); System.out.println(flatMapResult);
執行結果:[1,6,7,9]
示例場景:取出所有部門人員的姓名,就可以這樣寫(虛擬碼):
// 1、取出所有部門
List<Department> departments = ...;
// 2、這個時候可以利用flatMap先將所有部門的所有人員匯聚起來
List<Person> persons = departments.stream.flatMap(d->d.getPersonList()).collect(Collectors.toList());
// 3、再利用map()方法取出
4、distinct():顧名思義,將流中的元素去重之後輸出。
List<String> mzc = Stream.of("ma","chu","shuo","ma") .distinct() .collect(Collectors.toList()); System.out.println(mzc);
執行結果:[ma,zhi,chu,shuo]
5、sorted():這個很簡單了,顧名思義,將流中的元素按照自然排序方式進行排序。
// sorted:自然順序排序 List<Integer> nums = Arrays.asList(1,2); List<Integer> sortedNum = nums.stream().sorted().collect(Collectors.toList()); System.out.println(sortedNum); // sorted:降序排序 List<Integer> sortedNum2 = nums.stream().sorted(Comparator.reverseOrder()).collect(Collectors.toList()); System.out.println(sortedNum2); // sorted:使用Comparator List<Integer> sortedNums3 = nums.stream().sorted(Comparator.comparing(n -> n)).collect(Collectors.toList()); System.out.println(sortedNums3); // 不用stream直接順序排序 nums.sort(Comparator.comparing(Integer::intValue)); System.out.println(nums); //不用stream直接降序排序 nums.sort(Comparator.comparing(Integer::intValue).reversed()); System.out.println(nums);
執行結果:
[1,8]
[8,1]
[1,8]
[1,1]
6、peek():對流中每個元素執行操作,並返回一個新的流,返回的流還是包含原來流中的元素。
// peek(): String[] arr = new String[]{"a","b","c","d"}; Arrays.stream(arr) .peek(System.out::println) //a,b,c,d .count(); // peek()+filter() Stream.of("ma","chu") .filter(e -> e.length() > 2) .peek(e -> System.out.println(e)) .collect(Collectors.toList());
執行結果:
a
b
c
d
zhi
chu
7、limit():顧名思義,返回指定數量的元素的流。返回的是Stream裡前面的n個元素。
// limit():取出100中的前十個 List<Integer> limitNum = IntStream.range(1,100).limit(10) .boxed() .collect(Collectors.toList()); System.out.println(limitNum); // limit():取出前4個單詞 List<String> words = Arrays.asList("ma","wait","you","follow"); List<String> limitWord = words.stream().limit(4).collect(Collectors.toList()); System.out.println(limitWord);
執行結果:
[1,9,10]
[ma,wait]
8、skip():和limit()相反,將前幾個元素跳過(取出)再返回一個流,如果流中的元素小於或者等於n,就會返回一個空的流。
// skip():跳過前面三個單詞再返回 List<String> words = Arrays.asList("ma","follow"); List<String> skipWord = words.stream().limit(4).collect(Collectors.toList()); System.out.println(skipWord); // skip():跳過全部單詞再返回 List<String> emptyWord = words.stream().skip(6).collect(Collectors.toList()); System.out.println(emptyWord); // skip():跳過超過單詞長度的數目再返回 List<String> emptyWord2 = words.stream().skip(10).collect(Collectors.toList()); System.out.println(emptyWord);
執行結果:
[91,92,93,94,95,96,97,98,99]
[ma,wait]
[]
[]
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。