Java9 Stream API


流(Stream)是在Java中引入的,以幫助開發人員從一系列物件中執行聚合操作。在Java 9中,使用較少的方法就可以使流更好。

takeWhile(Predicate介面)

語法

default Stream<T> takeWhile(Predicate<? super T> predicate)

takeWhile方法獲取所有值直到predicate返回false。 在有序流的情況下,它返回一個流,該流包含從此流中匹配給定predicate的元素的最長字首。

範例

import java.util.stream.Stream;

public class Tester {
   public static void main(String[] args) {
      Stream.of("a","b","c","","e","f").takeWhile(s->!s.isEmpty())
         .forEach(System.out::print);
   } 
}

takeWhile方法獲取所有abc值,然後當字串為空,它將停止執行。

abc

dropWhile(Predicate介面)

語法

default Stream<T> dropWhile(Predicate<? super T> predicate)

dropWhile方法在開始時丟棄所有值,直到謂詞返回true。 在排序流的情況下,它返回包含該流剩餘元素的流後,刪除與給定predicate匹配的元素的最長字首。

範例

import java.util.stream.Stream;

public class Tester {
   public static void main(String[] args) {
      Stream.of("a","b","c","","e","f").dropWhile(s-> !s.isEmpty())
         .forEach(System.out::print);

      System.out.println();
      Stream.of("a","b","c","","e","","f").dropWhile(s-> !s.isEmpty())
         .forEach(System.out::print);
   } 
}

dropWhile方法刪除abc值,然後當字串為空,它將獲取所有值。

ef
ef

iterate語法

static <T> Stream<T> iterate(T seed, Predicate<? super T> hasNext, UnaryOperator<T> next)

iterate方法現在具有hasNext作為引數,當hasNext Predicate返回false,它將停止迴圈。

範例

import java.util.stream.IntStream;

public class Tester {
   public static void main(String[] args) {
      IntStream.iterate(3, x -> x < 10, x -> x+ 3).forEach(System.out::println);
   } 
}

執行上面程式碼,輸出結果如下 -

3
6
9

ofNullable語法

static <T> Stream<T> ofNullable(T t)

ofNullable方法被引入以防止NullPointerExceptions並避免對流進行空檢查。 此方法返回包含單個元素的順序流,如果非空(null)。否則返回空流。

語法

import java.util.stream.Stream;

public class Tester {
   public static void main(String[] args) {
      long count = Stream.ofNullable(100).count();
      System.out.println(count);

      count = Stream.ofNullable(null).count();
      System.out.println(count);
   } 
}

執行上面範例程式碼,得到以下結果 -

1
0