java8流(Stream API)使用详解:筛选、切片、映射、查找、匹配和归约等流操作

本文主要是介绍java8流(Stream API)使用详解:筛选、切片、映射、查找、匹配和归约等流操作,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

上一篇中介绍了集合操作的痛点并发现集合操作的这些痛点在java8流API面前基本都不是事,随后引出了流的定义并介绍了流操作的类型、特征,以及使用流的基本步骤,本篇将逐一介绍Stream Api中各种流操作及一些特殊流的使用。

用谓词筛选

关于筛选在该系列前面文章中已经出现多次了,这里再次列举如下,以求完整。
如下代码筛选出素食菜单:

 
  1. List<Dish> vegetarianMenu = menu.stream()
  2. .filter(Dish::isVegetarian)//方法引用检查是否为素食
  3. .collect(toList());

筛选去重:distinct()函数

去重是指去除筛选结果中的重复项,只需在fiter之后调用distinct()即可:

 
  1. List<Integer> numbers = Arrays.asList(1, 2, 1, 3, 3, 2, 4);
  2. numbers.stream().filter(i -> i % 2 == 0).distinct().forEach(System.out::println);

截短流:limit函数

截短流是指从流中截取部分数据,如取出热量大于300卡路里的前3道菜:

 
  1. List<Dish> dishes = menu.stream()
  2. .filter(d -> d.getCalories() > 300)
  3. .limit(3)//截短流
  4. .collect(toList());

跳过元素:skip(int)函数

跳过元素是指跳过流中指定数量的元素,对剩下的进行操作或取出,如下面的代码将跳过大于300卡路里的头3道菜:

 
  1. List<Dish> dishes = menu.stream()
  2. .filter(d -> d.getCalories() > 300)
  3. .skip(3)//跳过前3个元素
  4. .collect(toList());

当菜单流中热量大于300卡路里的菜不足3个时,上面的代码返回一个空的List<Dish>

映射:map

流的映射是指对流的每个元素应用一个指定的函数,使其映射成我们需要的新的元素。如从菜单中映射过菜名列表,代码如下:

 
  1. List<String> dishNames = menu.stream()
  2. .map(Dish::getName)//map映射
  3. .collect(toList());

菜单流Stream<Dish>经过map映射操作Dish::getName转换成了字符串流Stream<String>,即菜名流。

流的扁平化:flatMap

流的扁平化操作flatMap,通俗来将就是将多个流合并为一个流。
假如我们需要将给定的单词列表["Hello","World"]拆分为去重的字母列表["H","e","l", "o","W","r","d"],该怎么做?

尝试1:使用map与distinct

 
  1. //取得单词流Stream<String> 每个单词为一个字符串
  2. words.stream()
  3. //映射成Stream<String[]>,每个单词转换成了组成该单词的字符数组
  4. .map(word -> word.split(""))
  5. //去重,依然是String[]
  6. .distinct()
  7. //结果是List<String[]>
  8. .collect(toList());

尝试1宣告失败!

尝试2:使用map和Arrays.stream()

 
  1. //取得单词流Stream<String> 每个单词为一个字符串
  2. words.stream()
  3. //映射成Stream<String[]>,每个单词转换成了组成该单词的字符数组
  4. .map(word -> word.split(""))
  5. //Arrays::stream将每个字符数组转成字符流Stream<String>
  6. .map(Arrays::stream)
  7. .distinct()
  8. //结果是List<Stream<String>>
  9. .collect(toList());

尝试2宣告失败!

尝试3:使用flatMap

 
  1. List<String> uniqueCharacters =
  2. //取得单词流Stream<String> 每个单词为一个字符串
  3. words.stream()
  4. //映射成Stream<String[]>,每个单词转换成了组成该单词的字符数组
  5. .map(w -> w.split(""))
  6. //flatMap将每个字符数组转成的字符流Stream<String>扁平化为单个流Stream<String>
  7. .flatMap(Arrays::stream)
  8. //去除重复字符
  9. .distinct()
  10. //获取去重后的字符列表List<String>
  11. .collect(Collectors.toList());

尝试3宣告成功!

anyMatch:至少匹配一个元素

查找菜单中是否存在素食,一旦匹配到素食即退出并返回true

 
  1. if(menu.stream().anyMatch(Dish::isVegetarian)){
  2. System.out.println("找到素食!");
  3. }

allMatch:匹配所有元素

检测菜单中所有菜是不是都是健康食品(假设热量小于1000就是健康的):

 
  1. if(menu.stream().allMatch(d -> d.getCalories() < 1000)){
  2. System.out.println("所有菜都是健康的,因为热量都小于1000");
  3. }

noneMatch:所有元素都不匹配

 
  1. if(menu.stream().noneMatch(d -> d.getCalories() >= 1000)){
  2. System.out.println("所有菜都是健康的,因为热量都不大于1000");
  3. }

查找任意元素:findAny

例如找到菜单中的任何一样素食:

 
  1. Optional<Dish> dish = menu.stream().filter(Dish::isVegetarian).findAny();

findAny返回当前流中的任意一个元素。

java.util.Optional<T>是一个容器类,它包裹着T,如上面代码中的Optional<Dish>可以理解装着Dish的一个容器,且该Dish允许为空,可以通过optional.get()方法获取该容器装的东西,该系列后面的文章会详细介绍Optional类的用法。

查找第一个元素:findFirst()

找到第一个平方能被3整除的数:

 
  1. List<Integer> someNumbers = Arrays.asList(1, 2, 3, 4, 5);
  2. Optional<Integer> firstSquareDivisibleByThree =
  3. someNumbers.stream()
  4. .map(x -> x * x)
  5. .filter(x -> x % 3 == 0)
  6. .findFirst(); // 9

相比于findAny,findFirst在并行上有更多的限制,如果不关心找到哪个元素,推荐用findAny。

归约操作:利用reduce求和

归约操作是指将流中的所有元素反复组合起来,得到一个值。比如,将流中的元素求和:int sum = numbers.stream().reduce(0, (a, b) -> a + b);

为什么说是反复组合起来?
求和归约操作中是将指定的初始值0(reduce方法的第一个参数)与流中的第一个元素相加(表达为reduce的第二个参数BinaryOperator,我们传递是Lambda表达式(a, b) -> a + b)得到一个中间值后与流中的第二个元素相加,直至流中的所有元素都被累加完,得到最终的求和结果。

reduce只接受一个参数的重载函数

 
  1. Optional<Integer> sum = numbers.stream().reduce((a, b) -> (a + b));

区别是返回值变成了Optional。

归约操作:利用reduce求最大与最小值

 
  1. //求最大值
  2. Optional<Integer> max = numbers.stream().reduce(Integer::max);
  3. //求最小值
  4. Optional<Integer> min = numbers.stream().reduce(Integer::min);

注:reduce操作最重要的就是需要指定一个Lambda表达式或方法引用来将流中的两个元素依次结果来产生一个新值。

这篇关于java8流(Stream API)使用详解:筛选、切片、映射、查找、匹配和归约等流操作的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/372421

相关文章

Spring三级缓存解决循环依赖的解析过程

《Spring三级缓存解决循环依赖的解析过程》:本文主要介绍Spring三级缓存解决循环依赖的解析过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、循环依赖场景二、三级缓存定义三、解决流程(以ServiceA和ServiceB为例)四、关键机制详解五、设计约

spring IOC的理解之原理和实现过程

《springIOC的理解之原理和实现过程》:本文主要介绍springIOC的理解之原理和实现过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、IoC 核心概念二、核心原理1. 容器架构2. 核心组件3. 工作流程三、关键实现机制1. Bean生命周期2.

解决tomcat启动时报Junit相关错误java.lang.ClassNotFoundException: org.junit.Test问题

《解决tomcat启动时报Junit相关错误java.lang.ClassNotFoundException:org.junit.Test问题》:本文主要介绍解决tomcat启动时报Junit相... 目录tomcat启动时报Junit相关错误Java.lang.ClassNotFoundException

Gradle下如何搭建SpringCloud分布式环境

《Gradle下如何搭建SpringCloud分布式环境》:本文主要介绍Gradle下如何搭建SpringCloud分布式环境问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录Gradle下搭建SpringCloud分布式环境1.idea配置好gradle2.创建一个空的gr

JVM垃圾回收机制之GC解读

《JVM垃圾回收机制之GC解读》:本文主要介绍JVM垃圾回收机制之GC,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、死亡对象的判断算法1.1 引用计数算法1.2 可达性分析算法二、垃圾回收算法2.1 标记-清除算法2.2 复制算法2.3 标记-整理算法2.4

一文带你搞懂Redis Stream的6种消息处理模式

《一文带你搞懂RedisStream的6种消息处理模式》Redis5.0版本引入的Stream数据类型,为Redis生态带来了强大而灵活的消息队列功能,本文将为大家详细介绍RedisStream的6... 目录1. 简单消费模式(Simple Consumption)基本概念核心命令实现示例使用场景优缺点2

springboot集成Lucene的详细指南

《springboot集成Lucene的详细指南》这篇文章主要为大家详细介绍了springboot集成Lucene的详细指南,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以跟随小编一起... 目录添加依赖创建配置类创建实体类创建索引服务类创建搜索服务类创建控制器类使用示例以下是 Spring

Java调用Python的四种方法小结

《Java调用Python的四种方法小结》在现代开发中,结合不同编程语言的优势往往能达到事半功倍的效果,本文将详细介绍四种在Java中调用Python的方法,并推荐一种最常用且实用的方法,希望对大家有... 目录一、在Java类中直接执行python语句二、在Java中直接调用Python脚本三、使用Run

使用Python开发Markdown兼容公式格式转换工具

《使用Python开发Markdown兼容公式格式转换工具》在技术写作中我们经常遇到公式格式问题,例如MathML无法显示,LaTeX格式错乱等,所以本文我们将使用Python开发Markdown兼容... 目录一、工具背景二、环境配置(Windows 10/11)1. 创建conda环境2. 获取XSLT

Java根据IP地址实现归属地获取

《Java根据IP地址实现归属地获取》Ip2region是一个离线IP地址定位库和IP定位数据管理框架,这篇文章主要为大家详细介绍了Java如何使用Ip2region实现根据IP地址获取归属地,感兴趣... 目录一、使用Ip2region离线获取1、Ip2region简介2、导包3、下编程载xdb文件4、J