Java8的Stream用法

Java8 API新增了一个新的抽象流Stream，它可以执行非常复杂的查找、过滤和映射数据等操作。使用Stream API 对集合数据进行操作，就类似于使用 SQL 执行的数据库查询。Stream就是把集合数据看作流，流在管道中传输，我们可在管道中进行排序聚合等操作。

在平时写代码的过程中，涉及到集合操作时候，Stream API可以极大的提高我们的生产力，让我们写出高效率、干净、简洁的代码。Stream API有很多操作可供使用，这里主要介绍常用的几个方法。

基础Stream API

forEach

forEach是迭代流中的每一个元素。

@Test
public void testForeach() {Random random = new Random();List<Integer> list= new ArrayList<>();//random.ints(-100,100).limit(10).forEach(System.out::println);random.ints(-100,100).limit(10).forEach(t->list.add(t));System.out.println(list);
}

上述是用forEach迭代输出每一个-100至100的随机值，输出10个，还可以迭代进入一个新的List集合。

map

map对流中每个元素进行操作，返回一个新的流

@Test
public void testMap(){// 只是对流操作并不会改变原List中的数据//Stream<String> fruit=Stream.of("apple","orange","banner","pear");List<String> fruit = Arrays.asList("apple","orange","banner","pear");fruit.stream().sorted().map(String::toUpperCase).forEach(System.out::println);System.out.println(fruit);// 返回新的流List<String> newfruit = fruit.stream().map(v->v.toUpperCase()).collect(Collectors.toList());System.out.println(newfruit);
}

上述是对每个元素进行大写字母化，或输出或返回到新的集合中

filter

filter 方法用于通过设置的条件过滤出元素

/*** Long 数组选取不为Null和大于0的值* @param t* @return*/
public static Long[] removeNullAndZero(Long[] t) {List<Long> list = Arrays.asList(t);return list.stream().filter(v->v!=null && v>0).toArray(Long[] :: new);	
}/*** 选取String数组 不为Null的值* @param t* @return*/
public static String[] removeNullAndZero(String[] t) {List<String> list = Arrays.asList(t);return list.stream().filter(v->v!=null).toArray(String[] :: new);	
}

过滤Null或者大于0的元素

@Test
public void testFilter() {List<Integer> intList = Arrays.asList(8,2,4,1,8,3,10,6,6,15);List<Integer> newIntList=intList.stream().filter(i->i>5).sorted().distinct().collect(Collectors.toList());System.out.println(newIntList);
}

上述是过滤大于5的值，并且排序，取唯一的数字输出到新的集合。

parallelStream

parallelStream 是流并行处理程序的代替方法，相比较Stream是多管道操作。它就是基于ForkJoinPool执行并发任务的。

特点

  • 使用parallelStream可以简洁高效的写出并发代码。
  • parallelStream并行执行是无序的。
  • parallelStream提供了更简单的并发执行的实现，但并不意味着更高的性能，它是使用要根据具体的应用场景。如果cpu资源紧张parallelStream不会带来性能提升；如果存在频繁的线程切换反而会降低性能。
  • 任务之间最好是状态无关的，因为parallelStream默认是非线程安全的，可能带来结果的不确定性。

Github上对Parallel做了增强，有兴趣可以点击访问。

@Test
public void testParallel() {Random random = new Random();List<Integer> list= new ArrayList<>();random.ints(-10000,10000).limit(10000).forEach(t->list.add(t));long start = System.currentTimeMillis();list.stream().filter(e -> e > 1000 && e< 2000).collect(Collectors.toList());System.out.println("stream : " + (System.currentTimeMillis() - start) + "ms");start = System.currentTimeMillis();list.parallelStream().filter(e -> e > 1000 && e < 2000).collect(Collectors.toList());System.out.println("parallelStream : " + (System.currentTimeMillis() - start) + "ms");
}

测试并发处理速度，上述代码对此做了测试，测试结果parallelStream速度是稍快一点。

Count

Stream API还提供简单的统计操作。

@Test
public void testCount() {List<Integer> numList = Arrays.asList(6, 2, 4, 3, 7, 3, 5, 9);DoubleSummaryStatistics stats = numList.stream().mapToDouble((x) -> x).summaryStatistics();System.out.println("总个数 : " + stats.getCount());System.out.println("列表中最大的数 : " + stats.getMax());System.out.println("列表中最小的数 : " + stats.getMin());System.out.println("所有数之和 : " + stats.getSum());System.out.println("平均数 : " + stats.getAverage());
}

简单的统计的功能。

实际应用

我在实际项目对会有集合进行操作，使用Stream API能够帮我简洁的解决问题。下面是我实际使用场景。

对象类

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;@Data
@NoArgsConstructor
@AllArgsConstructor
public class Person {private String name;private Integer gender;private int age;private double height;
}

使用场景

构造数据

static List<Person> createPeople(){List<Person> people=new ArrayList<Person>();Person person=new Person("张三",0,30,2.8);people.add(person);person=new Person("李四",0,32,1.6);people.add(person);person=new Person("王五",1,32,2.0);people.add(person);person=new Person("王五",1,33,1.6);people.add(person);return people;
}

连接某一属性

需要并行显示，用,连接某一属性

@Test
public void CollectionStreamJoin(){List<Person> people=createPeople();Stream<Person> stream=people.stream();// 取出对象的name值，并用,连接String names = stream.map(v->v.getName()).collect(Collectors.joining(","));System.out.println(names);
}

获取某属性唯一值

根据某一个属性值，删选对象。只保留唯一的属性值

@Test
public void distinctList() {List<Person> people=createPeople();List<Person> distinctlist = people.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(Person::getName))),ArrayList::new));System.out.println(distinctlist);
}

多属性排序

需要用多个属性去进行排序

@Test
public void sortField() {List<Person> people=createPeople();people.sort(Comparator.comparing(Person::getAge).reversed().thenComparing(Person::getHeight));System.out.println(JSON.toJSONString(people));
}

分组后排序

对象列表先按照一个字段分组，并根据另一个字段的大小来排序，取第一个对象

@Test
public void getOnlyOneByField() {List<Person> people=createPeople();Map<String,Person> map =new HashMap<>();map = people.parallelStream().collect(Collectors.groupingBy(Person::getName,Collectors.collectingAndThen(Collectors.reducing((c1, c2) -> c1.getAge()>c2.getAge()?c1:c2),Optional::get)));System.out.println(map);
}

累加求和

根据某个属性值累加

@Test
public void accumulation(){List<Person> people=createPeople();int sumAge = people.stream().mapToInt(Person::getAge).sum();System.out.println(sumAge);
}

分组求和

根据某个属性分组，然后另外一个值求和

/*** 分组求和*/
@Test
public void groupSum(){List<Person> people=createPeople();Map<Integer, DoubleSummaryStatistics> summaryStatisticsMap = people.stream().collect(Collectors.groupingBy(Person::getGender,Collectors.summarizingDouble(Person::getHeight)));System.out.println(JSON.toJSONString(summaryStatisticsMap));
}

总结

使用Stream API可以让集合操作的代码更为简洁，提高生产力。而且本人在写Stream操作的时候，思想就跟写SQL语句类似，包括分组、聚合、过滤等操作，遇到难的可以在思维上借鉴下。

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

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

相关文章

Spring MVC：请求转发与请求重定向

Spring MVC：请求转发与请求重定向

Spring MVC 请求转发请求重定向附 请求转发 转发&#xff08; forward &#xff09;&#xff0c;指服务器接收请求后&#xff0c;从一个资源跳转到另一个资源中。请求转发是一次请求&#xff0c;不会改变浏览器的请求地址。 简单示例&#xff1a; 1.通过 String 类型的返回值…
阅读更多...
GO语言篇之反射

GO语言篇之反射

GO语言篇之反射 文章目录 GO语言篇之反射前言获取变量类型获取变量值获取结构体的字段&#xff0c;方法&#xff0c;动态地修改&#xff0c;调用结构体的字段和方法创建变量缺点 前言 Go语言可以在运行期间查看自身结构&#xff0c;在运行时动态地获取结构体的信息&#xff0c…
阅读更多...
人工智能训练？量子计算机？显卡！【为什么人工智能需要强大的显卡而不是处理器？量子计算机可以吗？】

人工智能训练？量子计算机？显卡！【为什么人工智能需要强大的显卡而不是处理器？量子计算机可以吗？】

人工智能硬件与量子计算机&#xff1a;未来的竞争与合作 人工智能&#xff08;AI&#xff09;领域的发展一直以来都与硬件技术密不可分。随着深度学习和神经网络的崛起&#xff0c;图形处理单元&#xff08;GPU&#xff09;等硬件成为了AI训练的主要工具。然而&#xff0c;量子…
阅读更多...
spring 理解

spring 理解

仅供个人学习&#xff0c;部分转自路人甲&#xff0c;侵删 spring容器 1.基本概念 2.Spring Ioc 容器 3.Spring Aop 4.数据访问 5.Spring MVC 6.事务管理 7.高级特性 8.整合其他框架 9.理解原理 基本概念 spring启动流程&#xff0c;加载配置文件&#xff0c;创建…
阅读更多...
2023年基因编辑行业研究报告

2023年基因编辑行业研究报告

第一章 行业发展概况 1.1 定义 基因编辑&#xff08;Gene Editing&#xff09;&#xff0c;又称基因组编辑&#xff08;Genome Editing&#xff09;或基因组工程&#xff08;Genome Engineering&#xff09;&#xff0c;是一项精确的科学技术&#xff0c;可以对含有遗传信息的…
阅读更多...
[JAVAee]Spring的基础介绍

[JAVAee]Spring的基础介绍

本文章介绍了Spring大致是什么,核心的功能. Spring是什么? Spring指的是Spring Framework(Spring框架). 支持广大的开发场景,能够使应用开发变得简单. 其集成了各种工具,还实现了底层的类的实例化和生命周期的管理. 简单来说,Spring就是拥有众多工具方法的IoC容器 容器?…
阅读更多...
常用百宝箱——日志处理

常用百宝箱——日志处理

目录 前言 一、logging库 二、logging日志等级 三、logging四大组件 四、封装示例 总结 前言 日志是记录特定时间段或事件的详细信息的文件或记录。它们通过时间戳和关键词或描述符来标识事件或行动。日志可以用于许多目的&#xff0c;例如&#xff1a;故障排除、网络安全…
阅读更多...
搭建springcloud注册中心eureka以及admin监控

搭建springcloud注册中心eureka以及admin监控

写该篇文章的目的是为了以后搭建微服务的时候避免踩坑 要求&#xff1a;搭建一个eureka-server注册中心&#xff0c;再构建两个eureka-client注册上去&#xff0c;然后再搭建admin服务注册到注册中心。实现在admin后管页面可观察已注册上去的服务 前提&#xff1a;使用的spri…
阅读更多...
Redis 初识与入门

Redis 初识与入门

1. 什么是Redis Redis 是一种基于内存的数据库&#xff0c;对数据的读写操作都是在内存中完成&#xff0c;因此读写速度非常快&#xff0c;常用于缓存&#xff0c;消息队列、分布式锁等场景。 Redis 提供了多种数据类型来支持不同的业务场景&#xff0c;比如 String(字符串)、…
阅读更多...
关系的定义及表示

关系的定义及表示

关系的定义及表示 1、若集合R是AA的子集&#xff0c;则称R是集合A上的二元关系&#xff0c;简称关系 例&#xff1a;A{1,2}&#xff0c; AA{<1,1>,<1,2>,<2,1>,<2,2>}&#xff0c;AA的任何一个子集都是A上的关系 如&#xff1a; R{<1,1>, &…
阅读更多...
java企业数据管理系统

java企业数据管理系统

项目介绍 此项目为企业数据管理系统的后端部分&#xff0c;前端部分请参考vue-admin&#xff0c;项目实现了菜单管理、用户管理、角色管理和权限管理四个基础模块&#xff0c;前端菜单管理结合动态路由可自由添加菜单。结合Shiro权限管理实现了菜单和按钮的权限控制。 ❝ 前端…
阅读更多...
贝塞尔曲线的一些资料收集

贝塞尔曲线的一些资料收集

一本免费的在线书籍&#xff0c;供你在非常需要了解如何处理贝塞尔相关的事情。 https://pomax.github.io/bezierinfo/zh-CN/index.html An algorithm to find bounding box of closed bezier curves? - Stack Overflow https://stackoverflow.com/questions/2587751/an-algo…
阅读更多...
歌曲推荐《最佳损友》

歌曲推荐《最佳损友》

最佳损友 陈奕迅演唱歌曲 《最佳损友》是陈奕迅演唱的一首粤语歌曲&#xff0c;由黄伟文作词&#xff0c;Eric Kwok&#xff08;郭伟亮&#xff09;作曲。收录于专辑《Life Continues》中&#xff0c;发行于2006年6月15日。 2006年12月26日&#xff0c;该曲获得2006香港新城…
阅读更多...
Python之OS模块

Python之OS模块

os模块负责程序与操作系统的交互&#xff0c;提供了访问操作系统底层的接口;即os模块提供了非常丰富的方法用来处理文件和目录。 使用的时候需要导入该模块:import os
阅读更多...
MojoTween：使用「Burst、Jobs、Collections、Mathematics」优化实现的Unity顶级「Tween动画引擎」

MojoTween：使用「Burst、Jobs、Collections、Mathematics」优化实现的Unity顶级「Tween动画引擎」

MojoTween是一个令人惊叹的Tween动画引擎&#xff0c;针对C#和Unity进行了高度优化&#xff0c;使用了Burst、Jobs、Collections、Mathematics等新技术编码。 MojoTween提供了一套完整的解决方案&#xff0c;将Tween动画应用于Unity Objects的各个方面&#xff0c;并可以通过E…
阅读更多...
HCIP学习-IPv6

HCIP学习-IPv6

目录 前置学习内容 IPv6解决的一些IPv4的缺陷 无限的地址 层次化的地址结构 即插即用 简化报文头部 IPv4和IPv6报头比较 端到端的网络罗完整性 安全性增强 挣钱QoS特性 IPv6地址介绍 格式 首选格式 压缩格式 内嵌IPv4地址格式的IPv6地址格式 IPv6的网络前缀和接…
阅读更多...
MySQL——数据的增删改

MySQL——数据的增删改

2023.9.12 本章开始学习DML (数据操纵语言) 语言。相关学习笔记如下&#xff1a; #DML语言 /* 数据操作语言&#xff1a; 插入&#xff1a;insert 修改&#xff1a;update 删除&#xff1a;delete */#一、插入语句 #方式一&#xff1a;经典的插入 /* 语法&#xff1a; insert …
阅读更多...
python协程学习

python协程学习

import asyncio import time import csv import queue import aiosqlite import timeconn None # 定义一个队列&#xff0c;用于传递数据 data_queue queue.Queue()# 启动写文件 # def callback(): # await # print(f"执行结果:{future.result()}") async…
阅读更多...
后端入门教程：从零开始学习后端开发

后端入门教程：从零开始学习后端开发

1. 编程基础 首先&#xff0c;作为一名后端开发者&#xff0c;你需要掌握至少一门编程语言。Python是一个很好的选择&#xff0c;因为它易于学习且功能强大。让我们从一个简单的示例开始&#xff0c;在控制台输出 "Hello, World!"。 2. 学习Web基础 了解Web开发基…
阅读更多...
图的学习，深度和广度遍历

图的学习，深度和广度遍历

一、什么是图 表示“多对多”的关系 包括&#xff1a; 一组顶点&#xff1a;通常用V&#xff08;Vertex&#xff09;表示顶点集合一组边&#xff1a;通常用E&#xff08;Edge&#xff09;表示边的集合 边是顶点对&#xff1a;(v, w)∈E&#xff0c;其中v,w∈V有向边<v, w&…
阅读更多...
最新文章

Copyright @ 2022~2023