Stream流-有解無憂

摘要

Stream 是對集合物件功能的增強，它專注于對集合物件進行各種非常便利、高效的聚合操作，或者大批量資料操作，通常我們需要多行代碼才能完成的操作，借助于Stream流式處理可以很簡單的實作，
Stream 不是集合元素，它不是資料結構并不保存資料，它是有關演算法和計算的，

創建Steam流

呼叫Collection.stream()函式創建一個Stream物件

Stream 介面的靜態方法 of 可以獲取陣列對應的流

List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();

String[] arr = {"張三", "李四", "王五"};
Stream<String> stream2 = Stream.of(arr);

常用方法

void forEach(Consumer<? super T> action)：該方法接收一個Consumer介面函式，會將每一個流元素交給該函式進行處理，此方法為終結方法，遍歷后不能再呼叫Stream流的其他方法，

Consumer<T>函式式介面是一個消費型介面， Consumer介面中包含抽象方法void accept(T t)，意為消費一個指定泛型的資料，
```
import java.util.stream.Stream;

public class Start {
    public static void main(String[] args) {
        String[] arr = {"張三", "李四", "王五"};
        Stream<String> stream2 = Stream.of(arr);

        stream2.forEach((name)->{
            System.out.println(name);
        });
    }
}
```

Stream<T> filter(Predicate<? super T> predicate) ：將一個流轉換成另一個子集流，此方法為終結方法，

Predicate<T>函式式介面，抽象方法boolean test(T t)用來對指定資料進行判斷是否滿足條件，

import java.util.stream.Stream;

public class Start {
    public static void main(String[] args) {
        //獲取Stream流
        String[] arr = {"張三", "李四", "王五"};
        Stream<String> stream2 = Stream.of(arr);

        //filter方法
        Stream<String> fil = stream2.filter((name) -> {
            return name.startsWith("張");
        });
        fil.forEach(name->System.out.println(name));       
    }
}

Stream<R> map(Function<? super T, ? extends R> mapper)：將流中的元素映射到另一個流中，

Function<T>函式式介面，可以將當前流中的T型別資料轉換為另一種R型別的流，

import java.util.stream.Stream;

public class Start {
    public static void main(String[] args) {
        //獲取Stream流
        String[] arr = {"1", "2", "3"};
        Stream<String> stream2 = Stream.of(arr);

        //map方法
        Stream<Integer> map = stream2.map((string) -> {
            return Integer.parseInt(string);
        });
        map.forEach(integer->System.out.println(integer));
    }
}

long count() ：統計流中元素的個數，此方法為終結方法，
Stream<T> limit(long n)：用于截取流中的元素，只取用前n個元素，此方法是延遲方法，可以繼續呼叫Stream流中的其他方法，
```
stream1.limit(2).forEach(name -> System.out.println(name));
```
Stream<T> skip(long n)：用于跳過流中的元素，跳過n個元素，獲取剩下的元素組成新流，此方法是延遲方法，
```
stream1.skip(1).forEach(name -> System.out.println(name));
```
static <T> Stream<T> concat(Stream<? extends T> a, Stream<? extends T> b)：Stream的靜態方法，將兩個流合并為一個流，
```
Stream.concat(stream1, stream2).forEach(string -> System.out.println(string));
```

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/124093.html

標籤：Java

上一篇：集合框架-ArrayList&Vector&LinkedList

下一篇：Java反射詳解