搜云库技术团队
文章永久连接：https://tech.souyunku.com/?p=2427
Java 中引入了流 ( Stream ) 的概念，真的是大大方便了我们 java 程序员，我们可以使用流从一系列对象中执行聚合操作。
其实，Java 8 中的流已经很强大了，而且只要涉及到 IO，只要涉及到对一系列数据进行操作，几乎都有流的影子。
当然了，Java 9 还不忘对其继续增强，这次的改进主要是如何设置停止流的条件上。为此在流的实例上提供了四个方法 takeWhile(Predicate Interface) 、iterate 、ofNullable 和 dropWhile(Predicate Interface)
takeWhile(Predicate Interface)
takeWhile(Predicate Interface) 方法会处理流中所有的数据，直到条件 predicate 返回 false 为止
该方法的原型如下
default Stream<T> takeWhile(Predicate<? super T> predicate)
takeWhile() 方法会返回一个有序的流 ( stream ) ，返回的流中包含了原始流中于给定条件 predicate 相匹配的所有元素的最长前缀。
注意： 并不是所有匹配的元素，而是最长匹配前缀，因为一旦某个元素的
pridicate返回false，就立刻停止了
范例
在当前工作区创建一个文件 StreamTakeWhileTester.java ，并输入以下代码
import java.util.stream.Stream;
public class StreamTakeWhileTester{
public static void main(String[] args)
{
Stream.of("I","love","you","","so","much").takeWhile(s->!s.isEmpty())
.forEach(System.out::print);
System.out.println();
}
}
运行结果如下
[penglei@tech.souyunku.com java9]$ javac StreamTakeWhileTester.java && java StreamTakeWhileTester
Iloveyou
可以看到，我们设置的条件是如果元素为空则停止 !s.isEmpty() ，其实就是只要元素不为空则一直获取
所以，后面的 so much 并不会输出
dropWhile(Predicate Interface)
dropWhile(Predicate Interface) 则正好与 takeWhile() 方法相反，它首先先抛弃所有的值，直到条件为 true ，然后处理其后的所有值
dropWhile() 方法的原型如下
default Stream<T> dropWhile(Predicate<? super T> predicate)
方法签名和 dropWhile() 简直一模一样，除了方法名不同外，但是，却是两个截然不同的逻辑
dropWhile() 方法也是返回一个有序的流，返回的是由与给定 predicate 匹配的元素开始 ( 但不包括自己 ) 的所有其后元素组成的流
范例
在当前工作区创建一个文件 StreamDropWhileTester.java ，并输入以下代码
import java.util.stream.Stream;
public class StreamDropWhileTester{
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);
}
}
运行结果如下
[penglei@tech.souyunku.com java9]$ javac StreamDropWhileTester.java && java StreamDropWhileTester
ef
ef
可以看到，空字符串之前的字符 a 、b、c 都被扔掉了，而且只返回了 ef
iterate()
iterate() 会循环遍历流中的数据，直到条件返回 false 时停止
该方法的原型如下
static <T> Stream<T> iterate(T seed, Predicate<? super T> hasNext, UnaryOperator<T> next)
看方法原型，是不是很像 for(){} 循环语句，第一个参数 seed 表示初始化循环变量，第二个参数 hasNext 则为循环终止条件，第三个参数 next 则用于生成下一个循环值
范例
在当前工作区创建一个文件 StreamIterateTester.java ，并输入以下代码
import java.util.stream.IntStream;
public class StreamIterateTester{
public static void main(String[] args) {
IntStream.iterate(3, x -> x < 20, x -> x+ 3).forEach(System.out::println);
}
}
运行结果如下
[penglei@tech.souyunku.com java9]$ javac StreamIterateTester.java && java StreamIterateTester
3
6
9
12
15
18
是不是很酷，简直就是另一个 for 循环语句啊
ofNullable()
ofNullable() 方法用来阻止 NullPointerExceptions并避免对流进行 null 检查
该方法的原型如下
static <T> Stream<T> ofNullable(T t)
按官方文档的解释，如果传递的元素 t 非空，则返回由参数元素组成的有序流，否则返回一个空的流
范例
在当前工作区创建一个文件 StreamOfNullableTester.java ，并输入以下代码
import java.util.stream.Stream;
public class StreamOfNullableTester{
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);
}
}
运行结果如下
[penglei@tech.souyunku.com java9]$ javac StreamOfNullableTester.java && java StreamOfNullableTester
1
0
干货推荐
附录：Java 9 新特性 系列文章
- 一、Java 9 新特性 – 介绍
- 二、Java 9 新特性 – 特性简介
- 三、Java 9 新特性 – 环境配置
- 四、Java 9 新特性 – 模块化
- 五、Java 9 新特性 – REPL ( JShell )
- 六、Java 9 新特性 – 改进 JavaDocs
- 七、Java 9 新特性 – 多版本共存 JAR
- 八、Java 9 新特性 – 集合不可变实例工厂方法
- 九、Java 9 新特性 – 接口 ( interface ) 的私有方法
- 十、Java 9 新特性 – 改进进程管理 API
- 十一、Java 9 新特性 – 增强流 ( Stream ) API
- 十二、Java 9 新特性 – try-with-resources 语句
- 十三、Java 9 新特性 – 增强 @Deprecated 注解
- 十四、Java 9 新特性 – 内部类的方块操作符
- 十五、Java 9 新特性 – Option 类
- 十六、Java 9 新特性 – 多分辨率图像 API
- 十七、Java 9 新特性 – CompletableFuture API ( 上 )
- 十八、Java 9 新特性 – CompletableFuture API ( 中 )
- 十九、Java 9 新特性 – CompletableFuture API ( 下 )
- 二十、Java 9 新特性 – 其它特性
