Fork me on GitHub

Java 9 Stream API变更

前言

Java 9 Stream API新增了 takeWhile / dropWhile, ofNullable ,iterate 等方法。

我们通过例子来了解下它们。

正文

使用takeWhile()和dropWhile()方法对流进行限制

新的方法takeWhiledropWhile允许我们根据谓词获取流的一部分。

这里的流可以是有序的,也可以是无序的,所以:

  1. 在一个有序的流上,takeWhile返回从流中取出的与给定谓词匹配的元素的“最长前缀”,从流的开头开始。
  2. 在一个无序流上,takeWhile从流的开头开始返回匹配给定谓词(但不是全部)的流元素的子集。

dropWhile方法与takeWhile方法相反。

  1. 在一个有序的流中,dropWhile返回与给定谓词匹配的“最长前缀”之后的剩余项。
  2. 在一个无序的流上,dropWhile在删除匹配给定谓词的元素子集后返回剩余的流元素。

takeWhile和dropWhile的例子

在本例中,我们有一个从’a’到’i’的字符List。我想要在迭代中获取出现在’d’之前的所有字符。

1
2
3
4
5
6
7
8
9
10
11
12
List<String> alphabets = List.of("a", "b", "c", "d", "e", "f", "g", "h", "i");

List<String> subset1 = alphabets
.stream()
.takeWhile(s -> !s.equals("d"))
.collect(Collectors.toList());

System.out.println(subset1);

Output:

[a, b, c]

如前所述,dropWhile的作用与takeWhile方法相反,因此在上面的例子中,如果使用dropWhile方法,它将返回takeWhile谓词所留下的所有字符。

1
2
3
4
5
6
7
8
9
10
11
12
List<String> alphabets = List.of("a", "b", "c", "d", "e", "f", "g", "h", "i");

List<String> subset2 = alphabets
.stream()
.dropWhile(s -> !s.equals("d"))
.collect(Collectors.toList());

System.out.println(subset2);

Output:

[d, e, f, g, h, i]

重载流的iterate方法

iterate()方法,用于创建以单个元素(the seed)开始的流,并通过连续应用一元运算符生成后续元素,结果是一个无限的流。

要终止流,需要使用限制或其他一些短路函数,如findFirstfindAny

Java 8中的iterate方法有这样的签名:

1
static Stream iterate(final T seed, final UnaryOperator f)

在Java 9中,新的重载版本的iterate将一个谓词作为第二个参数:

1
static Stream iterate(T seed, Predicate hasNext, UnaryOperator next)

让我们看看Java 8和Java 9之间iterate方法使用的不同之处。

iterate method in Java 8

1
2
3
4
5
6
7
8
9
List<Integer> numbers = Stream.iterate(1, i -> i+1)
.limit(10)
.collect(Collectors.toList());

System.out.println(numbers);

Output:

[1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

iterate method in Java 9

1
2
3
4
5
6
7
8
List<Integer> numbers = Stream.iterate(1, i -> i <= 10 ,i -> i+1)
.collect(Collectors.toList());

System.out.println(numbers);

Output:

[1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

在上面的例子中,第一个流是使用带有限制的iterate的Java 8方式。第二个使用谓词作为第二个参数。

新方法ofNullable()

在Java 8之前,流中不能有null值。它会导致NullPointerException

在Java 9中,ofNullable方法允许我们创建一个单元素流,该流包装一个值(如果不是null),或者是一个空流。

1
2
3
4
5
6
7
8
9
10
Stream<String> stream = Stream.ofNullable("123");
System.out.println(stream.count());

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

Output:

1
0

这里,count方法返回流中非空元素的数量。

从技术上讲,Stream.ofnullable()与在流API上下文中使用null条件检查非常相似。




-------------文章结束啦 ~\(≧▽≦)/~ 感谢您的阅读-------------

SakuraTears wechat
扫一扫关注我的公众号
您的支持就是我创作的动力!
0%