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();
}
}
运行结果如下
[yufei@www.twle.cn 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);
}
}
运行结果如下
[yufei@www.twle.cn 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);
}
}
运行结果如下
[yufei@www.twle.cn 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);
}
}
运行结果如下
[yufei@www.twle.cn java9]$ javac StreamOfNullableTester.java && java StreamOfNullableTester
1
0
Java 面试宝典是大明哥全力打造的 Java 精品面试题,它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题,而是一套完整的 Java 知识体系,一套你 Java 知识点的扫盲贴。
它的内容包括:
- 大厂真题:Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
- 原创内容:Java 面试宝典内容全部都是大明哥原创,内容全面且通俗易懂,回答部分可以直接作为面试回答内容。
- 持续更新:一次购买,永久有效。大明哥会持续更新 3+ 年,累计更新 1000+,宝典会不断迭代更新,保证最新、最全面。
- 覆盖全面:本宝典累计更新 1000+,从 Java 入门到 Java 架构的高频面试题,实现 360° 全覆盖。
- 不止面试:内容包含面试题解析、内容详解、知识扩展,它不仅仅只是一份面试题,更是一套完整的 Java 知识体系。
- 宝典详情:https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
- 宝典总览:https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
- 宝典进展:https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw
目前 Java 面试宝典累计更新 400+ 道,总字数 42w+。大明哥还在持续更新中,下图是大明哥在 2024-12 月份的更新情况:
想了解详情的小伙伴,扫描下面二维码加大明哥微信【daming091】咨询
同时,大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ,回复【面试题】 即可免费领取。