生活_傻大方

  1. 首页 > 潮·科技 > >

算我求你了！请避开Java Stream流式编程常见的坑

Java8 由Oracle在2014年发布 ， 是继Java5之后最具革命性的版本了 。
Java8吸收其他语言的精髓带来了函数式编程 ， lambda表达式 ， Stream流等一系列新特性 ， 学会了这些新特性 ， 可以让你实现高效编码优雅编码 。
1. Stream是什么？Stream是Java8新增的一个接口 ， 允许以声明性方式处理数据集合 。 Stream不是一个集合类型不保存数据 ， 可以把它看作是遍历数据集合的高级迭代器（Iterator） 。
Stream操作可以像Builder一样逐步叠加 ， 形成一条流水线 。 流水线一般由数据源+零或者多个中间操作+一个终端操作所构成 。 中间操作可以将流转换成另外一个流 ， 比如使用filter过滤元素 ， 使用map映射提取值 。
Stream与lambda表达式密不可分 ， 本文默认你已经掌握了lambda基础知识 。
2. Stream的特点

  • 只能遍历（消费）一次 。 Stream实例只能遍历一次 ， 终端操作后一次遍历就结束 ， 再次遍历需要重新生成实例 ， 这一点类似于Iterator迭代器 。
  • 保护数据源 。 对Stream中任何元素的修改都不会导致数据源被修改 ， 比如过滤删除流中的一个元素 ， 再次遍历该数据源依然可以获取该元素 。
  • 懒 。 filter, map 操作串联起来形成一系列中间运算 ， 如果没有一个终端操作（如collect）这些中间运算永远也不会被执行 。
3. 创建Stream实例的方法（1）使用指定值创建Stream实例
// of为Stream的静态方法Stream strStream = Stream.of("hello", "java8", "stream");// 或者使用基本类型流IntStream intStream = IntStream.of(1, 2, 3);复制代码（2）使用集合创建Stream实例（常用方式）
// 使用guava库 ， 初始化一个不可变的list对象ImmutableList integers = ImmutableList.of(1, 2, 3);// List接口继承Collection接口 ， java8在Collection接口中添加了stream方法Stream stream = integers.stream();复制代码（3）使用数组创建Stream实例
// 初始化一个数组Integer[] array = {1, 2, 3};// 使用Arrays的静态方法streamStream stream = Arrays.stream(array);复制代码（4）使用生成器创建Stream实例
// 随机生成100个整数Random random = new Random();// 加上limit否则就是无限流了Stream stream = Stream.generate(random::nextInt).limit(100);复制代码（5）使用迭代器创建Stream实例
// 生成100个奇数 ， 加上limit否则就是无限流了Stream stream = Stream.iterate(1, n -> n + 2).limit(100);stream.forEach(System.out::println);复制代码（6）使用IO接口创建Stream实例
// 获取指定路径下文件信息 ， list方法返回Stream类型Stream pathStream = Files.list(Paths.get("/"));复制代码4. Stream常用操作Stream接口中定义了很多操作 ， 大致可以分为两大类 ， 一类是中间操作 ， 另一类是终端操作；
算我求你了！请避开Java Stream流式编程常见的坑文章插图
（1）中间操作
中间操作会返回另外一个流 ， 多个中间操作可以连接起来形成一个查询 。
中间操作有惰性 ， 如果流上没有一个终端操作 ， 那么中间操作是不会做任何处理的 。
下面介绍常用的中间操作：
map操作
map是将输入流中每一个元素映射为另一个元素形成输出流 。
// 初始化一个不可变字符串List words = ImmutableList.of("hello", "java8", "stream");// 计算列表中每个单词的长度List list = words.stream().map(String::length).collect(Collectors.toList());// output: 5 5 6list.forEach(System.out::println);复制代码flatMap操作
List list1 = words.stream().map(word -> word.split("-")).collect(Collectors.toList());// output: [Ljava.lang.String;@59f95c5d, //[Ljava.lang.String;@5ccd43c2list1.forEach(System.out::println);复制代码哪里？你预期是List, 返回却是List, 这是因为split方法返回的是String[]
这个时候你可以想到要将数组转成stream, 于是有了第二个版本
Stream> arrStream = words.stream().map(word -> word.split("-")).map(Arrays::stream);// output: java.util.stream.ReferencePipeline$Head@2c13da15, // java.util.stream.ReferencePipeline$Head@77556fdarrStream.forEach(System.out::println);复制代码还是不对 ， 这个问题使用flatMap扁平流可以解决 ， flatMap将流中每个元素取出来转成另外一个输出流
Stream strStream = words.stream().map(word -> word.split("-")).flatMap(Arrays::stream).distinct();// output: hello java8 streamstrStream.forEach(System.out::println);复制代码filter操作
filter接收Predicate对象 ， 按条件过滤 ， 符合条件的元素生成另外一个流 。
// 过滤出单词长度大于5的单词 ， 并打印出来List words = ImmutableList.of("hello", "java8", "hello", "stream");words.stream().filter(word -> word.length() > 5).collect(Collectors.toList()).forEach(System.out::println);// output: stream复制代码



上一篇：绿皮J15新机的出现意味着什么？

下一篇：不爽的周鸿祎：人间大炮，一级准备、二级准备，射