1. 首页
  2. java9教程

009-九、Java 9 – 增强流 ( Stream ) API

Java 中引入了流 ( Stream ) 的概念,真的是大大方便了我们 java 程序员,我们可以使用流从一系列对象中执行聚合操作。

其实,Java 8 中的流已经很强大了,而且只要涉及到 IO,只要涉及到对一系列数据进行操作,几乎都有流的影子。

当然了,Java 9 还不忘对其继续增强,这次的改进主要是如何设置停止流的条件上。为此在流的实例上提供了四个方法 takeWhile(Predicate Interface)iterateofNullabledropWhile(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@www.ycbbs.vip 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@www.ycbbs.vip java9]$ javac StreamDropWhileTester.java && java StreamDropWhileTester ef ef

可以看到,空字符串之前的字符 abc 都被扔掉了,而且只返回了 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

是不是很酷,简直就是另一个 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@www.ycbbs.vip java9]$ javac StreamOfNullableTester.java && java StreamOfNullableTester

写完了如果写得有什么问题,希望读者能够给小编留言,也可以点击[此处扫下面二维码关注微信公众号](https://www.ycbbs.vip/?p=28 "此处扫下面二维码关注微信公众号")

JS中文网,Javascriptc中文网是中国领先的新一代开发者社区和专业的技术媒体,一个帮助开发者成长的社区,是给开发者用的 Hacker News,技术文章由为你筛选出最优质的干货,其中包括:Android、iOS、前端、后端等方面的内容。目前已经覆盖和服务了超过 300 万开发者,你每天都可以在这里找到技术世界的头条内容。

本文著作权归作者所有,如若转载,请注明出处

转载请注明:文章转载自「 Java极客技术学习 」https://www.javajike.com

标题:009-九、Java 9 – 增强流 ( Stream ) API

链接:https://www.javajike.com/article/1424.html

« 010-十、Java 9 – try-with-resources 语句
008-八、Java 9 – 改进进程管理 API»

相关推荐

QR code