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));