Java 9 Stream API改进


流是在Java中引入的,以帮助开发人员从一系列对象中执行聚合操作。使用Java 9,添加更少的方法可以使流更好。

takeWhile(谓词接口)


句法

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(谓词接口)

句法

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

dropWhile方法在开始时丢弃所有值,直到谓词返回true。在排序流的情况下,它返回一个由该流的其余元素组成的流,之后丢弃匹配给定谓词的元素的最长前缀。

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)

迭代方法现在具有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方法被引入以防止NullPointerExceptions并避免对流进行空检查。此方法返回包含单个元素的顺序流,如果非空,则返回空流。

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