Java9 Stream API改进

1 Java9 Stream API新增方法

在Java 9中，改进了Stream API，并将新方法添加到Stream接口。这些方法如下表所示。

修复

方法

描述

default Stream

takeWhile(Predicate super T> predicate)

如果此流是有序的，它将返回一个流，该流由与此流中匹配给定Predicate的元素的最长前缀组成。否则，如果此流是无序的，则返回一个流，该流由从该流中获取的与给定Predicate匹配的元素的子集组成。

default Stream

dropWhile(Predicate super T> predicate)

如果删除此流，则返回一个包含该流其余元素的流，然后删除与给定Predicate匹配的元素的最长前缀。否则，如果此流是无序的，则返回在删除与给定Predicate匹配的元素子集之后由该流的其余元素组成的流。

static Stream

ofNullable(T t)

如果不为null，则返回包含单个元素的顺序Stream，否则返回空Stream。

static Stream

iterate(T seed, Predicate super T> hasNext, UnaryOperator next)

以满足给定的hasNext的Predicate为条件，将通过将给定的next函数迭代应用到初始元素而产生的顺序有序Stream返回。当hasNext的Predicate返回false时，流终止。

2 Java Stream API：takeWhile()方法

Stream takeWhile方法采用与其Predicate匹配的每个元素。当得到不匹配的元素时，它停止。它返回包含所有匹配元素的元素子集，流的其他部分被丢弃。

3 Java Stream API：takeWhile()方法案例1

在此示例中，我们有一个整数列表，并使用takewhile方法获取了偶数值。

/**

* 一点教程网： http://www.yiidian.com

*/

import java.util.List;

import java.util.stream.Collectors;

import java.util.stream.Stream;

public class StreamExample {

public static void main(String[] args) {

List list

= Stream.of(1,2,3,4,5,6,7,8,9,10)

.takeWhile(i -> (i % 2 == 0)).collect(Collectors.toList());

System.out.println(list);

}

}

本示例返回一个空列表，因为它在第一个列表元素处失败，并且takewhile在此处停止。

输出结果为：

[]

4 Java Stream API：takeWhile()方法案例2

在此示例中，我们获得了前两个元素，因为它们是偶数且停在第三个元素。

/**

* 一点教程网： http://www.yiidian.com

*/

import java.util.List;

import java.util.stream.Collectors;

import java.util.stream.Stream;

public class StreamExample {

public static void main(String[] args) {

List list

= Stream.of(2,2,3,4,5,6,7,8,9,10)

.takeWhile(i -> (i % 2 == 0)).collect(Collectors.toList());

System.out.println(list);

}

}

输出结果为：

[2,2]

5 Java Stream API：dropWhile()方法

Stream dropWhile方法根据流元素的顺序返回结果。

有序流：在删除与给定Predicate匹配的元素后，返回包含元素的流。

无序流：在删除与给定Predicate匹配的元素子集之后，它返回包含该流剩余元素的流。

6 Java Stream API：dropWhile()方法案例

/**

* 一点教程网： http://www.yiidian.com

*/

import java.util.List;

import java.util.stream.Collectors;

import java.util.stream.Stream;

public class StreamExample {

public static void main(String[] args) {

List list

= Stream.of(2,2,3,4,5,6,7,8,9,10)

.dropWhile(i -> (i % 2 == 0)).collect(Collectors.toList());

System.out.println(list);

}

}

输出结果为：

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

7 Java Stream API：ofNullable()方法

Stream ofNullable方法返回包含单个元素(如果非null)的顺序流。否则，它将返回一个空流。

它有助于处理空流和NullPointerException。

8 Java Stream API：ofNullable()方法案例1

/**

* 一点教程网： http://www.yiidian.com

*/

import java.util.List;

import java.util.stream.Collectors;

import java.util.stream.Stream;

public class StreamExample {

public static void main(String[] args) {

List list

= Stream.of(2,2,3,4,5,6,7,8,9,10)

.dropWhile(i -> (i % 2 == 0)).collect(Collectors.toList());

System.out.println(list);

}

}

输出结果为：

25

Stream can have null values also.

9 Java Stream API：ofNullable()方法案例2

/**

* 一点教程网： http://www.yiidian.com

*/

import java.util.stream.Stream;

public class StreamExample {

public static void main(String[] args) {

Stream val

= Stream.ofNullable(null);

val.forEach(System.out::println);

}

}

该程序不会产生任何输出。

10 Java Stream API：迭代方法

新的重载方法iterate已添加到Java 9流接口。此方法允许我们迭代流元素直到指定条件。

它需要三个参数：seed，hasNext和next。

11 Java Stream API：迭代方法案例

/**

* 一点教程网： http://www.yiidian.com

*/

import java.util.stream.Stream;

public class StreamExample {

public static void main(String[] args) {

Stream.iterate(1, i -> i <= 10, i -> i*3)

.forEach(System.out::println);

}

}

输出结果为：

1

3

9