本文共 2809 字,大约阅读时间需要 9 分钟。
欢迎进入我的博客:blog.scarlettbai.com查看更多文章
stream
作为Java8的一个重要的新特性,其提供了对于集合的流处理模式,引出了管道的概念,即通过获取stream
流,之后可根据需要进行map、reduce处理,形象的比喻就是将集合想做一条流水,map、reduce则是管道,对流水进行了处理汇总统计等操作。
首先我们来看如下代码:
private static void getStream(){ Listlist = new ArrayList (Arrays.asList("读书","健身","编程")); System.out.println(list.stream()); list.stream().forEach(s -> System.out.println(s));}
执行结果如下:
java.util.stream.ReferencePipeline$Head@135fbaa4读书健身编程
list.stream()方法中会new一个ReferencePipeline
类,其中包含了filter、map、reduce等方法,大家可以点进去看下源码,看源码是个好习惯。
下面来看一些实际运用的例子:
一:filter过滤
还记得昨天写的过滤集合中的字符串长度大于4且以A结尾的例子吧,其实借助stream的filter可以更简单:private static void testStatic(){ Listlist = new ArrayList<>(Arrays.asList("aaaaA","aA","aaaaa")); list.stream().filter(str -> str.length() > 4 && str.endsWith("A")) .forEach(System.out::printf);}
输出结果:
aaaaA
filter顾名思义,就是对于stream流进行一个过滤操作,入参是一个lambda表达式,返回的还是一个stream,也就是说后面还可以跟一个filter或者别的流操作,不过此处需要注意的是filter返回的是一个新的集合,不是直接在以前的集合上做的remove。上面代码写成这样也是一样的:
private static void testStatic(){ Listlist = new ArrayList<>(Arrays.asList("aaaaA","aA","aaaaa")); list.stream().filter(str -> str.endsWith("A")) .filter(str -> str.length() > 4).forEach(System.out::printf);}
二:map修改集合中元素
stream流可以对于其中的元素通过map做处理,如将其中所有元素乘2:private static void testMap(){ Listlist = new ArrayList<>(Arrays.asList(5d,6d,3d,7d)); list.stream().map(d -> d*2).forEach(System.out::println);}
输出结果:
10.012.06.014.0
三:reduce处理
reduce可以对stream流进行聚合处理,比如我们要将上个例子中的所有元素想加:private static void testReduce(){ Listlist = new ArrayList<>(Arrays.asList(5d,6d,3d,7d)); System.out.println(list.stream().map(d -> d*2) .reduce(0d,(result , d) -> result +=d));}
输出结果:
42.0
可以看到,结果是将map中输出的元素做了想加操作,这里reduce分别有1、2、3个参数的方法,大家可以点亲自试一下各自的用法,当然和mongodb
等不一样的地方在于,这里的reduce不是必须要放在map后的,也可以不要map直接使用的。
四:distinct去重处理
distinct可以对集合进行去重处理,如:private static void testDistinct(){ Listlist = new ArrayList<>(Arrays.asList(5,6,3,7,3,1,5)); list.stream().distinct().forEach(System.out::println);}
输出结果:
56371
五:summaryStatistics做统计处理
stream通过mapToInt转换成IntStream后可以通过summaryStatistics方法来获取当前集合的状态量,比如最小值,最大值,平均值等,代码如下:private static void testSummary(){ Listlist = new ArrayList<>(Arrays.asList(5l,6l,3l,7l,1l)); IntSummaryStatistics status = list.stream().mapToInt(x -> x.intValue()).summaryStatistics(); System.out.println("minVaule=" + status.getMin()); System.out.println("maxVaule=" + status.getMax()); System.out.println("avgVaule=" + status.getAverage()); System.out.println("sum=" + status.getSum());}
输出结果:
minVaule=1maxVaule=7avgVaule=4.4sum=22
可以看到,通过这种方法可以很方便的对于集合做统计操作,当然这里不止有IntStream,还有DoubleStream和LongStream,原理是一样的,大家可以自己试试。
今天就先介绍到这里,大家有什么问题欢迎关注公众号后发消息提出。
欢迎关注个人微信公众号:读书健身编程