Java8 Stream流式编程,极大解放你的生产力!
java8自带常用的函数式接口
Predicate<T> boolean test(T t)
传入一个参数返回boolean值Consumer<T> void accept(T t)
传入一个参数,无返回值Function<T,R> R apply(T t)
传入一个参数,返回另一个类型
准备数据
//计算机俱乐部
private static List<Student> computerClub = Arrays.asList(new Student("2015134001", "小明", 15, "1501"),new Student("2015134003", "小王", 14, "1503"),new Student("2015134006", "小张", 15, "1501"),new Student("2015134008", "小梁", 17, "1505")
);
//篮球俱乐部
private static List<Student> basketballClub = Arrays.asList(new Student("2015134012", "小c", 13, "1503"),new Student("2015134013", "小s", 14, "1503"),new Student("2015134015", "小d", 15, "1504"),new Student("2015134018", "小y", 16, "1505")
);
//乒乓球俱乐部
private static List<Student> pingpongClub = Arrays.asList(new Student("2015134022", "小u", 16, "1502"),new Student("2015134021", "小i", 14, "1502"),new Student("2015134026", "小m", 17, "1504"),new Student("2015134027", "小n", 16, "1504")
);private static List<List<Student>> allClubStu = new ArrayList<>();
allClubStu.add(computerClub);
allClubStu.add(basketballClub);
allClubStu.add(pingpongClub);
常用的stream三种创建方式
集合
Collection.stream()
静态方法
Stream.of
数组
Arrays.stream
//1.集合
Stream<Student> stream = basketballClub.stream();
//2.静态方法
Stream<String> stream2 = Stream.of("a", "b", "c");
//3.数组
String[] arr = {"a","b","c"};
Stream<String> stream3 = Arrays.stream(arr);
Stream的终止操作
foreach(Consumer c)
遍历操作collect(Collector)
将流转化为其他形式max(Comparator)
返回流中最大值min(Comparator)
返回流中最小值count
返回流中元素综述
Collectors 具体方法
toList List<T>
把流中元素收集到ListtoSet Set<T>
把流中元素收集到SettoCollection Coolection<T>
把流中元素收集到Collection中groupingBy Map<K,List<T>>
根据K属性对流进行分组partitioningBy Map<boolean, List<T>>
根据boolean值进行分组
//此处只是演示 此类需求直接用List构造器即可
List<Student> collect = computerClub.stream().collect(Collectors.toList());
Set<Student> collect1 = pingpongClub.stream().collect(Collectors.toSet());
//注意key必须是唯一的 如果不是唯一的会报错而不是像普通map那样覆盖
Map<String, String> collect2 = pingpongClub.stream().collect(Collectors.toMap(Student::getIdNum, Student::getName));
//分组 类似于数据库中的group by
Map<String, List<Student>> collect3 = pingpongClub.stream().collect(Collectors.groupingBy(Student::getClassNum));
//字符串拼接 第一个参数是分隔符 第二个参数是前缀 第三个参数是后缀
String collect4 = pingpongClub.stream().map(Student::getName).collect(Collectors.joining(",", "【", "】"));//【小u,小i,小m,小n】
//三个俱乐部符合年龄要求的按照班级分组
Map<String, List<Student>> collect5 = Stream.of(basketballClub, pingpongClub, computerClub).flatMap(e -> e.stream().filter(s -> s.getAge() < 17)).collect(Collectors.groupingBy(Student::getClassNum));
//按照是否年龄>16进行分组 key为true和false
ConcurrentMap<Boolean, List<Student>> collect6 = Stream.of(basketballClub, pingpongClub, computerClub).flatMap(Collection::stream).collect(Collectors.groupingByConcurrent(s -> s.getAge() > 16));
Stream的中间操作
filter(Predicate)
筛选流中某些元素
//筛选1501班的学生
computerClub.stream().filter(e -> e.getClassNum().equals("1501")).forEach(System.out::println);
//筛选年龄大于15的学生
List<Student> collect = computerClub.stream().filter(e -> e.getAge() > 15).collect(Collectors.toList());
map(Function f)
接收流中元素,并且将其映射成为新元素,例如从student对象中取name属性
//篮球俱乐部所有成员名 + 暂时住上商标^_^,并且获取所有队员名
List<String> collect1 = basketballClub.stream().map(e -> e.getName() + "^_^").collect(Collectors.toList());
collect1.forEach(System.out::println);
//小c^_^^_^
//小s^_^^_^
//小d^_^^_^
//小y^_^^_^
flatMap(Function f)
将所有流中的元素并到一起连接成一个流
//获取年龄大于15的所有俱乐部成员
List<Student> collect2 = Stream.of(basketballClub, computerClub, pingpongClub).flatMap(e -> e.stream().filter(s -> s.getAge() > 15)).collect(Collectors.toList());
collect2.forEach(System.out::println);//用双层list获取所有年龄大于15的俱乐部成员
List<Student> collect3 = allClubStu.stream().flatMap(e -> e.stream().filter(s -> s.getAge() > 15)).collect(Collectors.toList());
collect3.forEach(System.out::println);
peek(Consumer c)
获取流中元素,操作流中元素,与foreach不同的是不会截断流,可继续操作流
//篮球俱乐部所有成员名 + 赞助商商标^_^,并且获取所有队员详细内容
List<Student> collect = basketballClub.stream().peek(e -> e.setName(e.getName() + "^_^")).collect(Collectors.toList());
collect.forEach(System.out::println);
//Student{idNum='2015134012', name='小c^_^', age=13, classNum='1503'}
//Student{idNum='2015134013', name='小s^_^', age=14, classNum='1503'}
//Student{idNum='2015134015', name='小d^_^', age=15, classNum='1504'}
//Student{idNum='2015134018', name='小y^_^', age=16, classNum='1505'}
distinct()
通过流所生成元素的equals和hashCode去重limit(long val)
截断流,取流中前val个元素sorted(Comparator)
产生一个新流,按照比较器规则排序sorted()
产生一个新流,按照自然顺序排序
List<String> list = Arrays.asList("b","b","c","a");
list.forEach(System.out::print); //bbca
List<String> collect = list.stream().distinct().sorted().collect(Collectors.toList());
collect.forEach(System.out::print);//abc
//获取list中排序后的top2 即截断取前两个
List<String> collect1 = list.stream().distinct().sorted().limit(2).collect(Collectors.toList());
collect1.forEach(System.out::print);//ab
匹配
booelan allMatch(Predicate)
都符合boolean anyMatch(Predicate)
任一元素符合boolean noneMatch(Predicate)
都不符合
boolean b = basketballClub.stream().allMatch(e -> e.getAge() < 20);
boolean b1 = basketballClub.stream().anyMatch(e -> e.getAge() < 20);
boolean b2 = basketballClub.stream().noneMatch(e -> e.getAge() < 20);
寻找元素
findFirst
——返回第一个元素findAny
——返回当前流中的任意元素
Optional<Student> first = basketballClub.stream().findFirst();
if (first.isPresent()) {Student student = first.get();System.out.println(student);
}Optional<Student> any = basketballClub.stream().findAny();
if (any.isPresent()) {Student student2 = any.get();System.out.println(student2);
}
Optional<Student> any1 = basketballClub.stream().parallel().findAny();
System.out.println(any1);
计数和极值
count
——返回流中元素的总个数max
——返回流中最大值min
——返回流中最小值
long count = basketballClub.stream().count();
Optional<Student> max = basketballClub.stream().max(Comparator.comparing(Student::getAge));
if (max.isPresent()) {Student student = max.get();
}
Optional<Student> min = basketballClub.stream().min(Comparator.comparingInt(Student::getAge));
if (min.isPresent()) {Student student = min.get();
}
END
推荐好文
强大,10k+点赞的 SpringBoot 后台管理系统竟然出了详细教程!分享一套基于SpringBoot和Vue的企业级中后台开源项目,代码很规范!
能挣钱的,开源 SpringBoot 商城系统,功能超全,超漂亮!
Java8 Stream流式编程,极大解放你的生产力!相关推荐
- Java8新特性之Stream流式编程
特地感谢鲁班大叔的分享,原学习地址:Java8 Stream流式编程爱 撸码就是快,流式编程好 代码传家宝 以下是学习过程整理的笔记 1.简介 Stream 流处理,首先要澄清的是 java8 中的 ...
- Lambda表达式和Stream流式编程
写在前面 IDEA都默认是jdk11了,我这还写着jdk8的新特性呢,惭愧惭愧.其实在学校的时候,基本没咋用过Lambda表达式和Stream流式编程,但是在实习的时候,发现公司的代码好多这样写的,没 ...
- java8/Stream流式计算从入门到精通/函数式编程实战
摘要:Stream流式计算,本文讲解了Stream流式计算的概念,具体的使用步骤以及源码实现,最后讲解了使用Stream过程中需要注意的事项.Stream在公司项目中被频繁使用,在性能优化上具有广泛的 ...
- [编程] Java8 Stream(流式计算) 常见的一些用法汇总
前提:以下基于 List<Student> 列表进行举例,大家实际使用进行举一反三即可.大同小异,Java8 的流式计算功能很强大,需要大家实际应用中逐渐挖掘更高级的用法. Student ...
- Java Stream流式编程
流式编程Stream 一.简介 流式 API 从 Java8 开始引入,支持链式书写. 流只能消费一次,不能被两次消费(两次最终操作) 流在管道中流通,在节点被处理. 流[无存储],流不是一种数据结构 ...
- Java8 Stream流式操作接口详解
stream是用于集合使用的流式操作,可使用collection.stream获取流 default Stream<E> stream() {return StreamSupport.st ...
- Java8 stream流式表达式用法
一.stream 介绍(抄录一波) Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方式来提供一种对 Java 集合运算和表达的高阶抽象. Stream API可以极大提高Java程序 ...
- 2022-08-08 java之 Stream流式编程
目录 一. 什么是 Stream 二.流操作 三.流与集合 什么时候计算 外部迭代和内部迭代 一次性的流 四. 一般方法 4.1. stream() / parallelStream() 4.2.fi ...
- Java8 :流式数据处理
java8的流式处理极大了简化我们对于集合.数组等结构的操作,让我们可以以函数式的思想去操作,本篇文章将探讨java8的流式数据处理的基本使用. 一. 流式处理简介 在我接触到java8流式处理的时候 ...
最新文章
- java中的重写与重载_java中的重写与重载
- Unit Three-Program test
- FusionChart完全入门手册8
- 我要去 Google 工作了
- OpenCV3学习(11.7) BRISK特征检测器及BRISK描述符
- ★LeetCode(1025)——除数博弈(JavaScript)
- 对不起,AI觉得你有虐童倾向,求职失败
- 银行客户交易行为预测:LightGBM模型
- nandflash驱动详解
- 适合财务人员的财务报表分析软件有哪些?
- 0基础跟着黑马程序员学微信小程序前端开发Day02(自学笔记)
- Excel阳历转农历VBA函数
- Gitee+PicGo+Typora图床搭建丨出现 Error: You must be logged in to use 的解决方法
- 5分钟快速学会使用Swiper.js,实现轮播图各种效果!
- 声纹识别数据:让疫情期间的“闻声识人”更安全
- navigator for mysql_SQL Navigator 7
- 数学建模实战9(聚类分析)
- 前端团队研发效能提升的探索与实践
- 请教一下如何使用mdx文件
- 原生 和html5 性能,原生开发与HTML5开发的对比
热门文章
- 小米A3真机开箱照片曝光:水滴屏+后置三摄
- 反转!继SDA之后 WiFi联盟、蓝牙技术联盟、JEDEC协会恢复华为会员资格
- 厉害了!春节不打烊年货30分钟即买即送 饿了么新上线650多家超市
- php开发神器 -- phpStudy
- Python在HTTP接口测试中的应用
- rest php,restAPI
- d3d9 抓取windows屏幕
- mybatis接口中的方法重载_MyBatis底层实现原理: 动态代理的运用
- Java Sokect编程之HTTP请求
- jQuery中append()、prepend()与after()、before()的区别