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的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED(默认)2.2 SUPPORTS2

Python函数作用域示例详解

《Python函数作用域示例详解》本文介绍了Python中的LEGB作用域规则,详细解析了变量查找的四个层级,通过具体代码示例,展示了各层级的变量访问规则和特性,对python函数作用域相关知识感兴趣... 目录一、LEGB 规则二、作用域实例2.1 局部作用域(Local)2.2 闭包作用域(Enclos

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》:本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存

Linux中压缩、网络传输与系统监控工具的使用完整指南

《Linux中压缩、网络传输与系统监控工具的使用完整指南》在Linux系统管理中,压缩与传输工具是数据备份和远程协作的桥梁,而系统监控工具则是保障服务器稳定运行的眼睛,下面小编就来和大家详细介绍一下它... 目录引言一、压缩与解压:数据存储与传输的优化核心1. zip/unzip:通用压缩格式的便捷操作2.

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os

java中新生代和老生代的关系说明

《java中新生代和老生代的关系说明》:本文主要介绍java中新生代和老生代的关系说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、内存区域划分新生代老年代二、对象生命周期与晋升流程三、新生代与老年代的协作机制1. 跨代引用处理2. 动态年龄判定3. 空间分

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》:本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器(Iterator)1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一

Java内存分配与JVM参数详解(推荐)

《Java内存分配与JVM参数详解(推荐)》本文详解JVM内存结构与参数调整,涵盖堆分代、元空间、GC选择及优化策略,帮助开发者提升性能、避免内存泄漏,本文给大家介绍Java内存分配与JVM参数详解,... 目录引言JVM内存结构JVM参数概述堆内存分配年轻代与老年代调整堆内存大小调整年轻代与老年代比例元空

深度解析Java DTO(最新推荐)

《深度解析JavaDTO(最新推荐)》DTO(DataTransferObject)是一种用于在不同层(如Controller层、Service层)之间传输数据的对象设计模式,其核心目的是封装数据,... 目录一、什么是DTO?DTO的核心特点:二、为什么需要DTO?(对比Entity)三、实际应用场景解析