Loading... # 1. Stream API概述 前置知识: <div class="preview"> <div class="post-inser post box-shadow-wrap-normal"> <a href="https://www.fangshirui.cn/index.php/archives/724/" target="_blank" class="post_inser_a no-external-link"> <div class="inner-image bg" style="background-image: url(https://www.fangshirui.cn/usr/themes/handsome/assets/img/sj/5.jpg);background-size: cover;"></div> <div class="inner-content" > <p class="inser-title">Java-[lambda表达式和函数式接口]</p> <div class="inster-summary text-muted"> 为什么叫λ?这个字符是小写的Λ。而Λ有自由变量的含义。概念前言lambda表达式是一个可传递的代码块,可以在以后执... </div> </div> </a> <!-- .inner-content #####--> </div> <!-- .post-inser ####--> </div> <div class="preview"> <div class="post-inser post box-shadow-wrap-normal"> <a href="https://www.fangshirui.cn/index.php/archives/731/" target="_blank" class="post_inser_a no-external-link"> <div class="inner-image bg" style="background-image: url(https://assets.fangshirui.cn/typecho/uploads/2020/11/4285162587.png);background-size: cover;"></div> <div class="inner-content" > <p class="inser-title">Java-[Optional<T>]</p> <div class="inster-summary text-muted"> 概念Optional类是Java8引入的新特性。Optional类主要解决的空指针异常问题(NullPointer... </div> </div> </a> <!-- .inner-content #####--> </div> <!-- .post-inser ####--> </div> Stream API 是Java8的一大亮点,是对集合(Collection)对象的极大增强。它专注于对集合对象进行各种非常便利、高效的聚合操作。或者大批量数据操作。Stream API借助于同样新提供的Lambda表达式,极大提高了编程效率和程序可读性。同时它提供了串行和并行两种模式进行聚合操作。并发模式能更充分的利用到多核处理器的优势,使用fork/join并行方法来拆分任务和加速处理过程。 通常编写并行代码很难,容易出错,但是使用Stream API无须编写一行多线程的代码就可以很方便的写出高性能的并发程序。所以说,Java8 中的 java.util.stream是一个函数式语言与多核时代综合影响下的产物。 ## 什么是聚合操作 在传统Java应用中,Java代码经常不得不依赖于关系型数据库的聚合操作来完成诸如以下的事项: * 客户每月平均消费金额 * 最昂贵的在售商品 * 取10个数据样本作为首页推荐 在Java的集合API中,仅仅有极少量的辅助性方法,更多时候是用Iterator来遍历集合,完成相关聚合应用逻辑。这是一种远不够高效、笨拙的方法。 ## 什么是Stream Stream不是集合元素,它不是数据结构,并不能保存数据,而是有关算法和计算的,更像一个高级版本的Iterator。 Stream如同一个迭代器Iterator,单向,不可往复,数据只能遍历一次,遍历一次过后就用尽了。 和迭代器不同的是,Stream可以并行化操作,迭代器只能命令式地串行化操作。使用并行化去遍历时,数据会被分成多个段,其中每一个都在不同的线程中处理,然后将结果一起输出,Stream的并行操作以来Java7中引入的Fork/Join框架进行拆分任务和加速处理过程。 Stream的另一大特点是数据源本身可以是无限的。 ## Stream的构成 当我们使用一个Stream时,通常包括3个基本步骤: * 获取一个数据源 * 数据转换 * 执行操作获取想要的结果 每次转换原有的Stream对象不改变,返回一个新的Stream对象,这就允许**对其操作可以像链条一样排列,变成一个管道**。 有多种生成Stream数据源的方式: * 从Collction和数组 * Collection.stream() * Collection.parallelStream() * Arrays.stream( T array) * Stream.of() * 从BufferedReader * java.io.BufferedReader.lines() * 静态工厂 * java.util.stream.IntStream.range() * 自己构建 * java.util.Spliterator * 其他 * Random.ints() 无限生成int范围的数 * Bitset.stream() ---------- # 2. Stream使用 ## 简单实例 ```java public class Test2 { public static void main(String[] args) { IntStream.range(1, 9).filter( x -> x <= 4).forEach(x -> System.out.print(x + " ")); } } // 输出 1 2 3 4 ``` ## Stream常用操作 主要分为两类,一类是中间操作,一类是终止操作。 中间操作会返回一个新的Stream流。 终止操作不会返回一个新的Stream流。 ### 中间操作 #### map 将一种类型的值映射成一个新值(可以不同类型也可以同类型)。 #### filter 遍历并筛选出满足条件的元素。 ### 终止操作 #### forEach() 终止操作,对每个元素进行某个操作 #### collect(Collectors.toList()) 终止操作,将Stream流生成一个List列表,也可以用 Collectors.toSet()生成Set集合。 #### count 终止操作,用于统计Stream中元素个数。 #### min 终止操作,挑选最小值 #### max 终止操作,挑选最大值 #### reduce 终止操作,从Stream计算一个值,计算条件是reduce参数。 ## Stream高级操作 ## 过滤 除了filter还有 ### distinct 该方法可以取出重复值,通过hascode和 equals ## 切分数据 ### limit(n) 截断Stream,保留n个元素 ### skip(n) 跳过n个元素 ## 映射 除了map还有 ### flatMap 它可以将Stream<String[]> 扁平化为 Stream<String> ![Stream-flatMap][1] ## 查找和匹配 返回bool值 ### allMatch 判断流中元素是否全部与给定条件匹配 ### anyMatch 判断流中元素只要有任意一个匹配给定条件即可 ### noneMatch 流中元素都不能匹配给定条件返回真 ### findFirst 获取流中匹配的第一个元素 ### findAny 获取流中匹配到的任意一个元素 ---------- # 3. 收集器 ## Collector接口 在前面介绍的内容里,我们知道终止操作collect需要接受一个Collector接口类型数据来完成数据收集任务。 ## Collectors Collectors是Collector的工厂类,它提供了大量的静态方法,这些方法都是返回了一个Collector收集器。 例程: ```java public class Test2 { public static void main(String[] args) { String[] str = {"hello", "world", "!"}; System.out.println(Stream.of(str).collect(Collectors.joining())); // 等价于 // System.out.println(String.join("", str)); } } ``` [1]: https://assets.fangshirui.cn/typecho/uploads/2020/11/1744032032.png 最后修改:2020 年 12 月 10 日 08 : 13 PM © 允许规范转载