JDK8中的 Stream流式编程用法优化（工具类在文章最后）

Java从JDK8起提供了Stream流这个功能，于是项目里出现了大量基于Stream流的写法。随着项目的进行，慢慢的代码中铺天盖地的都是下面的写法：

 List<User> userList = null;if (condition) {userList = new ArrayList<>();userList.add(User.builder().id(1L).name("张三").age(25).build());userList.add(User.builder().id(2L).name("李四").age(30).build());userList.add(User.builder().id(3L).name("王五").age(40).build());}...省略了的业务逻辑...List<User> users = userList.stream().filter(it-> it.getAge() > 28).collect(Collectors.toList());System.out.println(users);

上面的代码中，构建了一个包含3个User对象的List，然后取出了其中age大于28的User对象构成了新的List。相信如果在日常工作和学习中写过了大量的类似的代码，很容易能看出问题来，userList会出现为空的情况，这时候是很容易触发空指针异常的。所以我们在使用stream前通常都是需要做非空判断的。于是，优化后的代码出现了:

List<User> userList = null;
if (condition) {userList = new ArrayList<>();userList.add(User.builder().id(1L).name("张三").age(25).build());userList.add(User.builder().id(2L).name("李四").age(30).build());userList.add(User.builder().id(3L).name("王五").age(40).build());
}...省略了的业务逻辑...
if (userList != null) {List<User> users = userList.stream().filter(it-> it.getAge() > 28).collect(Collectors.toList());System.out.println(users);
}

更近一步，还可以这样写：

List<User> userList = null;
if (condition) {userList = new ArrayList<>();userList.add(User.builder().id(1L).name("张三").age(25).build());userList.add(User.builder().id(2L).name("李四").age(30).build());userList.add(User.builder().id(3L).name("王五").age(40).build());
}...省略了的业务逻辑...
List<User> users = Optional.of(userList).orElse(List.of()).stream().filter(it-> it.getAge() > 28).collect(Collectors.toList());
System.out.println(users);

到了这里，这已经是一段比较常规的业务代码了，但是它真的很丑有没有。作为一个业务研发人员，我为什么要考虑这么多呢？我不需要关注List是怎么转换成stream的，同样的，我也不关心为什么在使用完stream以后还要collect。于是，我将上面的流式代码封装成了工具类，上面的代码可以简化为：

List<User> userList = null;
if (condition) {userList = new ArrayList<>();userList.add(User.builder().id(1L).name("张三").age(25).build());userList.add(User.builder().id(2L).name("李四").age(30).build());userList.add(User.builder().id(3L).name("王五").age(40).build());
}...省略了的业务逻辑...
List<User> users = Streams.filter(userList, it-> it.getAge() > 28);
System.out.println(users);

同样的，也支持其他操作：

//返回年龄大于28的用户列表
List<User> filterUsers = Streams.filter(userList, it -> it.getAge() > 28);//返回年龄大于28的用户的姓名列表
List<String> filterNames = Streams.toList(userList, it -> it.getAge() > 28, User::getName);//返回年龄大于28的用户的姓名作为key, 年龄只作为value的map
Map<String, Integer> filterNameAndAgeMap = Streams.toMap(userList, it -> it.getAge() > 28, User::getName, User::getAge);//返回所有用户的姓名列表
List<String> allUserNames = Streams.toList(userList, User::getName);//返回所有用户的姓名作为key, 用户信息只作为value的map
Map<String, User> allUserMap = Streams.mappingToMap(userList, User::getName);//返回所有用户的姓名作为key, 年龄作为value的map
Map<String, Integer> nameAndAgeMap = Streams.toMap(userList, User::getName, User::getAge);//返回年龄大于28的第一个用户, 如果找不到则使用默认值
User user = Streams.findFirstOrElse(userList, it-> it.getAge() > 28, new User());//返回年龄大于28的第一个用户, 如果找不到则抛出异常
User user2 = Streams.findFirstOrThrow(userList, it-> it.getAge() > 28, "未找到符合条件的数据");

最后附上工具类源码供各位取用：

package com.zlyx.common.util;import java.util.*;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.stream.Collectors;public class Streams {public static <T> List<T> filter(List<T> dataList, Predicate<T> filter) {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).collect(Collectors.toList());}public static <T> Set<T> filter(Set<T> dataList, Predicate<T> filter) {return Optional.of(dataList).orElse(Set.of()).stream().filter(filter).collect(Collectors.toSet());}public static <T> T findFirstOrThrow(List<T> dataList) throws Exception {return findFirstOrThrow(dataList, "未找到符合条件的数据");}public static <T> T findFirstOrThrow(List<T> dataList, String errorMsg) throws Exception {return findFirstOrThrow(dataList, Objects::nonNull, errorMsg);}public static <T> T findFirstOrThrow(List<T> dataList, Predicate<T> filter, String errorMsg) throws Exception {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).findFirst().orElseThrow(() -> new Exception(errorMsg));}public static <T> T findFirstOrElse(List<T> dataList, T defaultValue) {return findFirstOrElse(dataList, Objects::nonNull, defaultValue);}public static <T> T findFirstOrElse(List<T> dataList, Predicate<T> filter, T defaultValue) {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).findFirst().orElse(defaultValue);}public static <T, R> R findAnyOrNull(List<T> dataList, Function<T, R> mapper) {return Optional.of(dataList).orElse(List.of()).stream().map(mapper).filter(Objects::nonNull).findAny().orElse(null);}public static <T, R> R findAnyOrThrow(List<T> dataList, Function<T, R> mapper, String errorMsg) throws Exception {return Optional.of(dataList).orElse(List.of()).stream().map(mapper).filter(Objects::nonNull).findAny().orElseThrow(() -> new Exception(errorMsg));}public static <T, R> Set<R> toSet(List<T> dataList, Function<T, R> mapper) {return toSet(dataList, Objects::nonNull, mapper);}public static <T, R> Set<R> toSet(List<T> dataList, Predicate<T> filter, Function<T, R> mapper) {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).map(mapper).collect(Collectors.toSet());}public static <T, R> List<R> toList(List<T> dataList, Function<T, R> mapper) {return toList(dataList, Objects::nonNull, mapper);}public static <T, R> List<R> toList(List<T> dataList, Predicate<T> filter, Function<T, R> mapper) {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).map(mapper).distinct().collect(Collectors.toList());}public static <T, K> Map<K, T> mappingToMap(List<T> dataList, Function<T, K> keyMapper) {return mappingToMap(dataList, Objects::nonNull, keyMapper);}public static <T, K> Map<K, T> mappingToMap(List<T> dataList, Predicate<T> filter, Function<T, K> keyMapper) {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).collect(Collectors.toMap(keyMapper, it -> it, (v1, v2) -> v2));}public static <T, K, V> Map<K, V> toMap(List<T> dataList, Function<T, K> keyMapper, Function<T, V> valueMapper) {return toMap(dataList, Objects::nonNull, keyMapper, valueMapper);}public static <T, K, V> Map<K, V> toMap(List<T> dataList, Predicate<T> filter, Function<T, K> keyMapper, Function<T, V> valueMapper) {return Optional.of(dataList).orElse(List.of()).stream().filter(filter).collect(Collectors.toMap(keyMapper, valueMapper));}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.pswp.cn/bicheng/82405.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

uni-app学习笔记十二-vue3中组件传值(对象传值）

uni-app学习笔记十二-vue3中组件传值(对象传值）

一.单对象传值 父组件定义对象的值 <template><view><UserInfo :obj"userinfo"></UserInfo></view> </template><script setup>import {ref} from "vue"const userinfo ref({name:"蛛儿",avatar:&…
阅读更多...
UV-python环境管理工具 入门教程

UV-python环境管理工具 入门教程

在学习使用 MCP 的时候接触到了 UV 这个环境管理工具&#xff0c;经过对比&#xff0c;发现它在诸多方面比 venv、conda 等工具更为出色&#xff0c;因此整理了这份简单的入门学习笔记&#xff0c;希望能帮助大家快速上手。 介绍 UV 是一款集 Python 版本管理、虚拟环境创建与…
阅读更多...
【漫话机器学习系列】277.梯度裁剪（Gradient Clipping）

【漫话机器学习系列】277.梯度裁剪（Gradient Clipping）

【深度学习】什么是梯度裁剪&#xff08;Gradient Clipping&#xff09;&#xff1f;一张图彻底搞懂&#xff01; 在训练深度神经网络&#xff0c;尤其是 RNN、LSTM、Transformer 这类深层结构时&#xff0c;你是否遇到过以下情况&#xff1a; 模型 loss 突然变成 NaN&#xf…
阅读更多...
零基础弄懂 ngx_http_slice_module分片缓存加速

零基础弄懂 ngx_http_slice_module分片缓存加速

一、为什么需要 Slice&#xff1f; 在 NGINX 反向代理或 CDN 场景中&#xff0c;大文件&#xff08;视频、软件包、镜像等&#xff09;常因单体体积过大而令缓存命中率低、回源代价高。 ngx_http_slice_module 通过把一次完整响应拆分成 固定大小的字节块&#xff08;Slice&am…
阅读更多...
机器人强化学习入门学习笔记（三）

机器人强化学习入门学习笔记（三）

强化学习&#xff08;Reinforcement Learning, RL&#xff09;与监督学习不同——你不需要预先准备训练数据集&#xff0c;而是要设计环境、奖励函数&#xff0c;让智能体通过交互不断探索和学习。 &#x1f3af; 一、强化学习和训练数据的关系 强化学习不依赖固定的数据集。它…
阅读更多...
【python实战】二手房房价数据分析与预测

【python实战】二手房房价数据分析与预测

个人主页&#xff1a;大数据蟒行探索者 目录 一、数据分析目标与任务 1.1背景介绍 1.2课程设计目标与任务 1.3研究方法与技术路线 二、数据预处理 2.1数据说明 2.2数据清洗 2.3数据处理 三、数据探索分析 四、数据分析模型 五、方案评估 摘要&#xff1a;随着社会经…
阅读更多...
Kotlin IR编译器插件开发指南

Kotlin IR编译器插件开发指南

在 Kotlin 中开发基于 IR&#xff08;Intermediate Representation&#xff09;的编译器插件&#xff0c;可以深度定制语言功能或实现高级代码转换。以下是分步骤指南&#xff1a; 一、IR 编译器插件基础 IR 是什么&#xff1f; Kotlin 编译器将源码转换为 IR 中间表示&#xf…
阅读更多...
如何用 python 代码复现 MATLAB simulink 的 PID

如何用 python 代码复现 MATLAB simulink 的 PID

MATLAB在 Simulink 里做以下设置MATLAB 脚本调用示例 python 实现离散 PID 实现&#xff08;并行形式&#xff09; Simulink 中两种 PID 结构&#xff08;并联形式, I-形式&#xff09;下连续/离散时域里积分增益 I 的表示并联&#xff08;Parallel&#xff09; vs 理想&#x…
阅读更多...
黑马点评--基于Redis实现共享session登录

黑马点评--基于Redis实现共享session登录

集群的session共享问题分析 session共享问题&#xff1a;多台Tomcat无法共享session存储空间&#xff0c;当请求切换到不同Tomcat服务时&#xff0c;原来存储在一台Tomcat服务中的数据&#xff0c;在其他Tomcat中是看不到的&#xff0c;这就导致了导致数据丢失的问题。 虽然系…
阅读更多...
SkyWalking启动失败：OpenSearch分片数量达到上限的完美解决方案

SkyWalking启动失败：OpenSearch分片数量达到上限的完美解决方案

🚨 问题现象 SkyWalking OAP服务启动时报错： org.apache.skywalking.oap.server.library.module.ModuleStartException: java.lang.RuntimeException: {"error":{"root_cause":[{"type":"validation_exception", "reason&q…
阅读更多...
向量数据库选型实战指南：Milvus架构深度解析与技术对比

向量数据库选型实战指南：Milvus架构深度解析与技术对比

导读&#xff1a;随着大语言模型和AI应用的快速普及&#xff0c;传统数据库在处理高维向量数据时面临的性能瓶颈日益凸显。当文档经过嵌入模型处理生成768到1536维的向量后&#xff0c;传统B-Tree索引的检索效率会出现显著下降&#xff0c;而现代应用对毫秒级响应的严苛要求使得…
阅读更多...
MySQL#秘籍#一条SQL语句执行时间以及资源分析

MySQL#秘籍#一条SQL语句执行时间以及资源分析

背景 一条 SQL 语句的执行完&#xff0c;每个模块耗时&#xff0c;不同资源(CPU/IO/IPC/SWAP)消耗情况我该如何知道呢&#xff1f;别慌俺有 - MySQL profiling 1. SQL语句执行前 - 开启profiling -- profiling (0-关闭 1-开启) -- 或者&#xff1a;show variables like prof…
阅读更多...
【数据结构】实现方式、应用场景与优缺点的系统总结

【数据结构】实现方式、应用场景与优缺点的系统总结

以下是编程中常见的数据结构及其实现方式、应用场景与优缺点的系统总结&#xff1a; 一、线性数据结构 1. 数组 (Array) 定义&#xff1a;连续内存空间存储相同类型元素。实现方式&#xff1a;int[] arr new int[10]; // Javaarr [0] * 10 # Python操作&#xff1a; 访问&…
阅读更多...
PyTorch中cdist和sum函数使用示例详解

PyTorch中cdist和sum函数使用示例详解

以下是PyTorch中cdist与sum函数的联合使用详解： 1. cdist函数解析 功能：计算两个张量间的成对距离矩阵 输入格式： X1：形状为(B, P, M)的张量X2：形状为(B, R, M)的张量p：距离类型（默认2表示欧式距离）输出：形状为(B, P, R)的距离矩阵，其中元素 d i j d_{ij} dij​表示…
阅读更多...
Ansible配置文件常用选项详解

Ansible配置文件常用选项详解

Ansible 的配置文件采用 INI 格式&#xff0c;分为多个模块&#xff0c;每个模块包含特定功能的配置参数。 以下是ansible.cfg配置文件中对各部分的详细解析&#xff1a; [defaults]&#xff08;全局默认配置&#xff09; inventory 指定主机清单文件路径&#xff0c;默认值为 …
阅读更多...
了解FTP搜索引擎

了解FTP搜索引擎

根据资料&#xff0c; FTP搜索引擎是专门搜集匿名FTP服务器提供的目录列表&#xff0c;并向用户提供文件信息的网站&#xff1b; FTP搜索引擎专门针对FTP服务器上的文件进行搜索&#xff1b; 就是它的搜索结果是一些FTP资源&#xff1b; 知名的FTP搜索引擎如下&#xff0c; …
阅读更多...
【大模型面试每日一题】Day 28：AdamW 相比 Adam 的核心改进是什么？

【大模型面试每日一题】Day 28：AdamW 相比 Adam 的核心改进是什么？

【大模型面试每日一题】Day 28&#xff1a;AdamW 相比 Adam 的核心改进是什么&#xff1f; &#x1f4cc; 题目重现 &#x1f31f;&#x1f31f; 面试官&#xff1a;AdamW 相比 Adam 的核心改进是什么&#xff1f; #mermaid-svg-BJoVHwvOm7TY1VkZ {font-family:"trebuch…
阅读更多...
C++系统IO

C++系统IO

C系统IO 头文件的使用 1.使用系统IO必须包含相应的头文件&#xff0c;通常使用#include预处理指令。 2.头文件中包含了若干变量的声明&#xff0c;用于实现系统IO。 3.头文件的引用方式有双引号和尖括号两种&#xff0c;区别在于查找路径的不同。 4.C标准库提供的头文件通常没…
阅读更多...
多模态理解大模型高性能优化丨前沿多模态模型开发与应用实战第七期

多模态理解大模型高性能优化丨前沿多模态模型开发与应用实战第七期

一、引言 在前序课程中&#xff0c;我们系统剖析了多模态理解大模型&#xff08;Qwen2.5-VL、DeepSeek-VL2&#xff09;的架构设计。鉴于此类模型训练需消耗千卡级算力与TB级数据&#xff0c;实际应用中绝大多数的用户场景均围绕推理部署展开&#xff0c;模型推理的效率影响着…
阅读更多...
各个网络协议的依赖关系

各个网络协议的依赖关系

网络协议的依赖关系 学习网络协议之间的依赖关系具有多方面重要作用&#xff0c;具体如下&#xff1a; 帮助理解网络工作原理 - 整体流程明晰&#xff1a;网络协议分层且相互依赖&#xff0c;如TCP/IP协议族&#xff0c;应用层协议依赖传输层的TCP或UDP协议来传输数据&#…
阅读更多...
最新文章

Copyright @ 2022~2023