Java8新特性Stream流实例详解
作者:我不是李大侠 发布时间:2023-05-04 12:55:05
什么是Stream流?
Stream流是数据渠道,用于操作数据源(集合、数组等)所生成的元素序列。
Stream的优点:声明性,可复合,可并行。这三个特性使得stream操作更简洁,更灵活,更高效。
Stream的操作有两个特点:可以多个操作链接起来运行,内部迭代。
Stream可分为并行流与串行流,Stream API 可以声明性地通过 parallel() 与sequential() 在并行流与顺序流之间进行切换。串行流就不必再细说了,并行流主要是为了为了适应目前多核机器的时代,提高系统CPU、内存的利用率,并行流就是把一个内容分成多个数据块,并用不同的线程分别处理每个数据块的流。java1.8并行流使用的是fork/join框架,关于fork/join框架可参考http://ifeve.com/talk-concurrency-forkjoin/学习。
注意 :
* 1、Stream不会自己存储数据。
* 2、Stream不会改变原对象,他们会返回一个新的Stream。
* 3、Stream操作是延迟的,他们会等到需要的结果时才执行。
* 4、使用并行流并不一定会提高效率,因为jvm对数据进行切片和切换线程也是需要时间的。
本文主要讲 Stream的3个操作步骤:1、创建Stream 2、中间操作3、终止操作。
创建Stream
创建Stream,就是将一个数据源 (如:集合、数组)转化为一个流。
1、通过Collection系列提供的stream()(串行) 或parallelStream()(并行)获取数据流。
2、通过Arrays中的静态方法stream() 获取数据流。
3、通过Stream类中的静态方法of()获取数据流。
//1、通过Collection系列提供的stream()(串行) 或parallelStream()(并行)获取
List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();//串行流
Stream<String> stream2 = list.parallelStream();//并行流
//2、通过Arrays中的静态方法stream() 获取数据流
User[] u = new User[2];
Stream<User> stream3 = Arrays.stream(u);
//3、通过Stream;类中的静态方法of()
Stream<String> stream4 = Stream.of("11","2");
中间操作
中间操作,即对数据源进行一系列的操作处理。
多个中间操作可以连接起来性格一条流水线,除非流水线上触发器终止操作,否则中间操作不会执行任何的处理,而是在终止操作时一次性全部处理,成为惰性求值。
筛选和切片
1、filter(predicate)-接收lambda,从流中排除某些元素。
2、limit(n)-截断流,使其元素不超过给定数量。
3、skip(n)-跳过元素,返回一个扔掉了前n个元素的流。若流中元素不足n个,则返回一个空流,与limit(n)互补。
4、distinct-筛选,通过流所生成元素的hashcode()和equals()去重复元素。
/**
* 打印年龄大于18的前4位用户信息(不重复)
* 并跳过第1个用户
*/
@Test
public void test1(){
list.stream()
.filter((x)->x.getAge()>18)
.distinct()
.limit(4)
.skip(1).forEach(System.out::println);
}
映射
1、map,接收Lambda,将元素转换成其他形式或提取信息。接收一个函数作为参数,该函数会被应用到每一个元素上,并将其映射成一个新的元素。
2、mapToDouble/mapToInt/mapToLong,接收一个函数作为参数,该函数会被应用到每个元素上,产生一个新的DoubleStream/IntStream/LongStream。
3 、flatMap,接收一个函数作为参数,将流中的每个值都换成一个流,然后把流连接成一个流。
@Test
public void test2(){
///map
list.stream().map(User::getName)
.forEach(System.out::println);
//flatMap
List<List<User>> list1 = new ArrayList<>();
list1.add(list);
list1.stream().flatMap(Stream::getNames)
.forEach(System.out::println);
}
public static Stream<String> getNames(List<User> list){
List<String> list1 = new ArrayList<String>();
for (User user : list) {
list1.add(user.getName());
}
return list1.stream();
}
排序
1、sorted(),产生一个新流,其中按自然顺序排序。
2、sorted(Comparator),产生一个新流,其中按比较器顺序排序。
@Test
public void test3(){
List<String> list =Arrays.asList("aa","bb","cc","dd");
list.stream().sorted()
.forEach(System.out::println);
//
list.stream().sorted((x,y) -> {
if(x.equals(y)){
return 1;
}else{
return -1;
}
} ).forEach(System.out::println);
}
终止操作
终止操作是执行中间操作链,并产生结果(一个新流),数据源本身并不受影响,其结果可以是任何不是流的值。
查找与匹配
1、allMatch,检查是否匹配所有元素。
2、anyMatch,检查是否至少匹配一个元素。
3、noneMatch,检查是否没有匹配所有元素。
4、findFirst,返回第一个元素。
5、findAny,返回当前流中的任意元素。
6、count,返回流中元素的总数。
7、 max,返回流中最大值。
8、min,返回流中最小值。
9、froEach(Consumer c) 内部迭代。
@Test
public void test4(){
boolean b = list.stream().
noneMatch((e) ->
e.getName().equals("zhao"));
System.out.println(b);
Optional<User> op = list.parallelStream()
.filter((x) -> x.getAge() == 18)
.findAny();
System.out.println(op.get());
}
归约
reduce,可以将流中的值反复结合起来,得到一个值。
@Test
public void test5(){
//转List
List<String> list1 =list.stream()
.map(User::getName)
.collect(Collectors.toList()) ;
list1.forEach(System.out::println);
//转HashSet
HashSet<String> set = list.stream().
map(User::getName)
.collect(Collectors.toCollection(HashSet::new));
set.forEach(System.out::println);
//总数
Long count = list.stream()
.collect(Collectors.counting());
System.out.println(count);
//平均年龄
double avAge = list.stream()
.collect(Collectors.averagingInt(User::getAge));
System.out.println(avAge);
//总年龄
int toAge = list.stream()
.collect(Collectors.summingInt(User::getAge));
System.out.println(toAge);
//最大值
Optional<User> u = list.stream()
.collect(Collectors.maxBy((e1,e2)
-> Integer.compare(e1.getAge(),e2.getAge() )));
System.out.println(u);
//平均年龄
IntSummaryStatistics collect = list.stream()
.collect(Collectors.summarizingInt(User::getAge));
System.out.println(collect.getAverage());
//分组
Map<Integer, List<User>> l= list.stream()
.collect(Collectors.groupingBy(User::getAge));
System.out.println(l);
//多级分组
Map<Integer,Map<String,List<User>> > ls= list.stream()
.collect(Collectors.groupingBy(
User::getAge,Collectors.groupingBy(User::getSex)));
System.out.println(ls);
//分区
Map<Boolean,List<User>> map= list.stream()
.collect(Collectors.partitioningBy((x)
-> x.getAge()>18));
System.out.println(map);
//连接字符串
String str = list.stream().map(User::getName)
.collect(Collectors.joining(",","-","-"));
System.out.println(str);
}
总结
以上所述是小编给大家介绍的Java8新特性Stream流实例详解网站的支持!
来源:http://blog.csdn.net/l18637220680/article/details/78323998?utm_source=tuicool&utm_medium=referral
猜你喜欢
- 使用wpf程序常常会出现一个问题,那就是内存占用过高,使用wpf的程序功能越复杂往往用着用着内存就本着90往上去了。一方面wpf本身是一个u
- 自定义View,1. 自定义一个Runnable线程TouchEventCountThread , 用来统计500ms内的点击次
- OAuth2简介OAuth 是一个开放标准,该标准允许用户让第三方应用访问该用户在某一网站上存储的私密资源(如头像、照片、视频等),而在这个
- 打包与运行在项目开发完成之后,可以直接用IDEA将其打包成JAR包运行,也可以打包成WAR包运行以便在多服务器、多配置环境下运行。双击cle
- Python是一种广泛使用的解释型、高级编程、通用型编程语言,由吉多·范罗苏姆创造,第一版发布于1991年。可以视之为一种改良(加入一些其他
- Filter过滤器中访问getSession()要进行转化public void doFilter(ServletRequest reque
- 最近项目中使用了mybatis-plus 3.1.1版本,发现使用lambda表达式方式的条件构造器,执行时会报错;但是我用单元测试却通过,
- 1. 自动内存管理和GC在原始程序中堆的内存分配是这样的:找到第一个有足够空间的内存地址(没被占用的),然后将该内存分配。当程序不再需要此内
- 目录方案一,更改启动项方案二,禁用检查应用程序的CAS发布者策略方案一,更改启动项出问题应用的启动项是使用的默认设置,查看App.g.cs文
- 1.导包(1)c3p0 数据库连接池c3p0配置文件加入到src目录下(2)dbutils:对jdbc操作进行了封装it-cast工具包 包
- SpringMVC RESTFul访问首页实现一、新建 index.html在 webapp\WEB-INF\templates 下新建首页
- 1.预警需求为了更好的管理商品日期,需要对仓库的商品进行预警管理,对商品的保质期控制在一个范围内提示出来,也可以通过该功能间接的展示出一个商
- 1.分页类package org.zh.basic;/** * 页面类 * * @author keven&
- 安装Java:安装J2SE开发工具包5.0(JDK 5.0)下载:Java官方网站。请确保以下环境变量设置,如下所述:JAVA_HOME:
- 词云简介“词云”由美国西北大学新闻学副教授、新媒体专业主任里奇·戈登(Rich Gordon)于2006年最先使用,是通过形成“关键词云层”
- 一、使用线程的理由1、可以使用线程将代码同其他代码隔离,提高应用程序的可靠性。2、可以使用线程来简化编码。3、可以使用线程来实现并发执行。二
- java 中 * 机制的实例讲解在学习Spring的时候,我们知道Spring主要有两大思想,一个是IoC,另一个就是AOP,对于IoC,
- 注册BeanPostProcessorrefresh()调用registerBeanPostProcessors(beanFactory)方
- java 中newInstance()方法和new关键字的区别* 它们的区别在于创建对象的方式不一样,前者是使用类加载机制,后者是创建一个新
- 我们在设计layout的时候,使用Split视图,就是左侧是代码,右侧是设计图,但是我们忽视了最上方的工具栏,这里才是真正的宝藏。下面教大家