Java9 流 API 改进

Streams 是 Java 中引入的一种机制，用于帮助开发人员从对象序列中执行聚合操作。在 Java 9 中，还添加了一些方法来优化流的功能。

takeWhile(Predicate 接口)

语法

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

takeWhile方法会取出所有满足条件的值，直至条件返回false。如果流是有序的，它将返回一个由满足给定条件的流元素组成的最长前缀流。

示例

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方法获取所有的a、b和c的值，一旦字符串为空，它就停止执行。

abc

dropWhile（Predicate接口）

语法

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

dropWhile方法会丢弃开始部分的所有值，直到predicate返回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方法会删除a、b和c的值，一旦字符串为空，它就会取出所有的值。

ef
ef

迭代

语法

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

iterate方法现在具有hasNext谓词作为参数，当hasNext谓词返回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方法被引入是为了防止NullPointerException并避免对流进行空检查。如果非空，该方法返回一个包含单个元素的顺序流，否则返回一个空流。

示例

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