java1.8的stream_JDK1.8新特性(一):stream

搜索热词

一.什么是stream?

1.概述

Java 8 API添加了一个新的抽象称为流Stream,可以让你以一种声明的方式处理数据。

这种风格将要处理的元素集合看作一种流, 流在管道中传输, 并且可以在管道的节点上进行处理, 比如筛选, 排序,聚合等。

元素流在管道中经过中间操作的处理,最后由最终操作得到前面处理的结果。

简单描述一下大概是这样:

b747592f7cbd874a75548c383039a515.png

二. 举个例子?

现在有一个字符串集合,我们需要过滤掉集合里头长度小于2的字符串:

public static void main( String[] args ) {

List strings = Arrays.asList("ab","","bc","cd","abcd","jkl");

List stringList = new ArrayList<>();

for (String str : strings){

//如果长度大于2

if (str.length() >= 2){

//将字符串添加至新集合

stringList.add(str);

}

}

strings = stringList;

}

如果使用stream实现一模一样的效果:

public static void main( String[] args ) {

List strings = Arrays.asList("ab","jkl");

//通过stream操作集合

strings = strings.stream()

//去掉长度小于2的字符串

.filter(s -> s.length() >= 2)

//转回集合

.collect(Collectors.toList());

}

可见,使用streamAPI可以轻松写出更高效,更简洁,可读性更强的代码

三. 如何使用stream?

简单的说,分两步:生成流,操作流

1. 生成流

Stream 的创建需要指定一个数据源,比如 java.util.Collection的子类,List或者Set, 不支持Map

1.1 Collection接口的stream()或parallelStream()方法

//将Set或List集合直接转换为stream对象

List personList = new ArrayList<>();

Set set = new HashSet<>();

Stream personStream1 = personList.stream();//生成串行流

Stream personStream2 = set.parallelStream();//生成并行流

1.2 Stream.of(),Arrays.stream,Stream.empty()方法

String[] strArr = {"a","a","a"};

//Stream.empty()

Stream integerStream = Stream.empty();

//Stream.of() (方法内部调用的还是Arrays.stream)

Stream stringStream = Stream.of(strArr);

//Arrays.stream

Stream stringStream2 = Arrays.stream(strArr);

1.3 Stream.concat()方法

//已有的对象

Stream integerStream = Stream.empty();

Stream stringStream = Stream.of(strArr);

Stream stringStream2 = Arrays.stream(strArr);

//合并两个流

Stream conStream1 = Stream.concat(stringStream,integerStream);

Stream conStream2 = Stream.concat(stringStream,stringStream2);

1.4 静态的Files.lines(path)

File file = new File("D://test.txt");

Stream lines = Files.lines(file);

2. 操作流

Stream 操作分为中间操作或者最终操作两种,最终操作返回一特定类型的计算结果,而中间操作返回Stream本身,可以在后头跟上其他中间操作

//接下来的示例代码基于此集合

List strings = Arrays.asList("ab","jkl");

2.1 filter(Predicate:将结果为false的元素过滤掉

//去掉长度小于2的字符串

strings = strings.stream()

.filter(s -> s.length() >= 2)

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings

[ab,bc,cd,abcd,jkl]

2.2 map(fun):转换元素的值,可以引用方法或者直接用lambda表达式

strings = strings.stream()

//为每个字符串加上“???”

.map(s -> s += "???")

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings

[ab???,???,bc???,cd???,abcd???,jkl???]

2.3 limit(n):保留前n个元素

strings = strings.stream()

//保留前3个

.limit(3)

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings

[ab,bc]

2.4 skip(n):跳过前n个元素

strings = strings.stream()

//跳过前2个

.skip(2)

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings

[bc,jkl]

2.5 distinct():剔除重复元素

strings = strings.stream()

//过滤重复元素

.distinct()

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings(过滤掉了一个空字符串)

[ab,jkl]

2.6 sorted():通过Comparable对元素排序

strings = strings.stream()

//按字符串长度排序

.sorted(

//比较字符串长度

Comparator.comparing(s -> s.length())

)

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings(过滤掉了一个空字符串)

[,ab,jkl,abcd]

2.7 peek(fun):流不变,但会把每个元素传入fun执行,可以用作调试

strings = strings.stream()

//为字符串增加“???”

.peek(s -> s += "???")

//返回集合

.collect(Collectors.toList());

System.out.println(strings);

//打印strings,和map对比,实际并没有改变集合

[ab,jkl]

2.8 flatMap(fun):若元素是流,将流摊平为正常元素,再进行元素转换

//将具有多重嵌套结构的集合扁平化

//获取一个两重集合

List strings = Arrays.asList("ab","jkl");

List strings2 = Arrays.asList("asd","bzxasdc","cddsdsd","adsdsg","jvcbl");

List> lists = new ArrayList<>();

lists.add(strings);

lists.add(strings2);

//获取将两重集合压成一层

List stringList = lists.stream()

//将两重集合的子元素,即集合strings和strings2转成流再平摊

.flatMap(Collection::stream)

//返回集合

.collect(Collectors.toList());

System.out.println(stringList);

//打印stringList

[ab,asd,bzxasdc,cddsdsd,adsdsg,jvcbl]

2.9 anyMatch(fun),allMatch(fun):判断流中的元素是否匹配 【最终操作】

//allMatch

Boolean isAllMatch = strings.stream()

//判断元素中是否有匹配“ab”的字符串,返回true或fals

//判断元素中的字符串是否都与“ab”匹配,返回true或fals

.allMatch(str -> str.equals("ab"));

System.out.println(isMatch);

//anyMatch

Boolean isAnyMatch = strings.stream()

//判断元素中是否有匹配“ab”的字符串,返回true或fals

.anyMatch(str -> str.equals("ab"));

System.out.println("isAnyMatch:" + isAnyMatch);

System.out.println("isAllMatch:" + isAllMatch);

//打印结果

isAnyMatch:true

isAllMatch:false

2.10 forEach(fun): 迭代流中的每个数据 【最终操作】

strings.stream()

//遍历每一个元素

.forEach(s -> System.out.print(s + "; "));

2.11 collect():返回结果集 【最终操作】

strings = strings.stream()

//返回集合

.collect(Collectors.toList());

四. 使用IntSummaryStatistics类处理数据

1. IntSummaryStatistics类

IntSummaryStatistics类,在 java8中配合Stream使用,是用于收集统计信息(例如计数,最小值,最大值,总和和*平均值)的状态对象。

这个类长这样:

public class IntSummaryStatistics implements IntConsumer {

private long count;

private long sum;

private int min = Integer.MAX_VALUE;

private int max = Integer.MIN_VALUE;

public IntSummaryStatistics() { }

@Override

public void accept(int value) {

++count;

sum += value;

min = Math.min(min,value);

max = Math.max(max,value);

}

public void combine(IntSummaryStatistics other) {

count += other.count;

sum += other.sum;

min = Math.min(min,other.min);

max = Math.max(max,other.max);

}

public final long getCount() {

return count;

}

public final long getSum() {

return sum;

}

public final int getMin() {

return min;

}

public final int getMax() {

return max;

}

public final double getAverage() {

return getCount() > 0 ? (double) getSum() / getCount() : 0.0d;

}

@Override

public String toString() {

return String.format(

"%s{count=%d,sum=%d,min=%d,average=%f,max=%d}",this.getClass().getSimpleName(),getCount(),getSum(),getMin(),getAverage(),getMax());

}

}

2.使用

这个类的理解起来很简单,内部有这几个方法:

2.1 获取总条数:getCount(),

2.2 获取和:getSum(),

2.3 获取最小值:getMin(),

2.4 获取最大值:getMax(),

2.5 获取平均值:getAverage()

示例如下:

public static void main( String[] args ) {

List integerList = Arrays.asList(3,4,22,31,75,32,54);

IntSummaryStatistics sta = integerList

.stream()

//将元素映射为对应的数据类型(int,double,long)

.mapToInt(i -> i)

//转换为summaryStatistics类

.summaryStatistics();

System.out.println("总共有 : "+ sta.getCount());

System.out.println("列表中最大的数 : " + sta.getMax());

System.out.println("列表中最小的数 : " + sta.getMin());

System.out.println("所有数之和 : " + sta.getSum());

System.out.println("平均数 : " + sta.getAverage());

}

//打印结果

总共有 : 7

列表中最大的数 : 75

列表中最小的数 : 3

所有数之和 : 221

平均数 : 31.571428571428573

相关文章

总结

如果觉得编程之家网站内容还不错,欢迎将编程之家网站推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。

如您喜欢交流学习经验,点击链接加入交流1群:1065694478(已满)交流2群:163560250

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

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

相关文章

[C++STL]常用集合算法

代码如下: #include <iostream> #include <vector> #include <numeric> #include <algorithm> using namespace std;class myPrint { public:void operator()(int val){cout << val << " ";} };void test01() {vector<int&g…

Seek the Name, Seek the Fame POJ - 2752 (理解KMP函数的失配)既是S的前缀又是S的后缀的子串

题意&#xff1a;给一个字符串S&#xff0c; 求出所有前缀pre&#xff0c;使得这个前缀也正好是S的后缀。 输出所有前缀的结束位置。 就是求前缀和后缀相同的那个子串的长度 然后从小到大输出,主要利用next数组求解。 例如 “ababcababababcabab”&#xff0c; 以下这些前缀…

2020 年了,WPF 还有前途吗?

2020年了&#xff0c;微软的技术也不断更新了, .Net Core 3.1、.Net Framework 4.8以及今年11月推出的.NET 5...win10平台也普及了很多&#xff0c;WPF可以在上面大展身手&#xff0c;可性能和内存占用还是不行&#xff0c;但是WPF强大的UI能力很吸引人。WPF已经凉了吗? 学WPF…

[C++STL]常用查找算法

代码如下: #include <iostream> #include <algorithm> #include <vector> #include <string> using namespace std;void test01() {vector<int>v;for (int i 0; i < 10; i){v.push_back(i);}vector<int>::iterator it find(v.begin(…

php asp 语法,ASP 语法

在我们的 ASP 教程中&#xff0c;每个实例都提供隐藏的 ASP 源代码。这样会使您更容易理解它们的工作原理。向浏览器写输出ASP 文件通常包含 HTML 标签&#xff0c;就像 HTML 文件。然而&#xff0c;ASP 文件也能包含服务器脚本&#xff0c;这些脚本被分隔符 包围起来。服务器脚…

#10003. 「一本通 1.1 例 4」加工生产调度(贪心)

加工生产调度 题目描述 某工厂收到了n个产品的订单&#xff0c;这n个产品分别在A、B两个车间加工&#xff0c;并且必须先在A车间加工后才可以到B车间加工。 某个产品i在A、B两车间加工的时间分别为Ai、Bi。询问怎样安排这n个产品的加工顺序&#xff0c;才能使总的加工时间最短…

不要把异常当做业务逻辑,这性能可能你无法承受

一&#xff1a;背景1. 讲故事在项目中摸爬滚打几年&#xff0c;应该或多或少的见过有人把异常当做业务逻辑处理的情况(┬&#xff3f;┬)&#xff0c;比如说判断一个数字是否为整数,就想当然的用try catch包起来&#xff0c;再进行 int.Parse&#xff0c;如果抛异常就说明不是整…

[设计模式]开闭原则

开闭原则: 对扩展开放&#xff0c;对修改关闭。 增加功能是提过增加代码来实现的&#xff0c;而不是去修改源代码。 代码如下: #include <iostream> #include <string> using namespace std;class Caculaor { public:Caculaor(int a,int b,string c):a(a),b(b…

#10010 「一本通 1.1 练习 6」糖果传递 (数学+贪心)

题目描述 原题来自&#xff1a;HAOI 2008 有 n个小朋友坐成一圈&#xff0c;每人有 ai 颗糖果。每人只能给左右两人传递糖果。每人每次传递一颗糖果的代价为 1 。求使所有人获得均等糖果的最小代价。 输入格式 第一行有一个整数 &#xff0c;n表示小朋友个数&#xff1b; …

ASP.NET Core在Docker下面生成简易验证码

背景 验证码这个功能是十分常见的&#xff0c;各大系统的登录页面都会有。今天介绍一下最为普通的验证码。无论最终给到前端的是图片格式的验证码还是base64格式的验证码&#xff0c;其实都离不开这样的一步操作&#xff0c;都要先在后台生成一个图片。就个人经验来说&#xff…

[设计模式]迪米特法则

迪米特法则 又叫最少知识法则 类中的成员属性和成员方法&#xff0c;如果不需要对外暴露&#xff0c;就不要设成public。 代码如下: #include <iostream> #include <string> using namespace std;class AbstractBuilding { public:virtual void sale() 0; };cl…

#10017 「一本通 1.2 练习 4」传送带+三分套三分

题目描述 原题来自&#xff1a;SCOI 2010 在一个 2 维平面上有两条传送带&#xff0c;每一条传送带可以看成是一条线段。两条传送带分别为线段 AB和线段CD 。lxhgww 在 AB上的移动速度为 P &#xff0c;在 CD上的移动速度为 Q &#xff0c;在平面上的移动速度R 。 现在 l…

程序员过关斩将--从用户输入手机验证码开始

点击“蓝字”关注我们吧菜菜哥&#xff0c;请教个问题呗&#xff1f;说说看&#xff0c;能否解决不敢保证哦最近做的App业务中&#xff0c;有很多敏感操作需要用户输入手机验证码这没问题&#xff0c;手机验证码主要是为了验证当前操作人的有效性&#xff0c;有什么问题呢&…

Ticket Game CodeForces - 1215D(博弈题,巴什博弈思维)

题意&#xff1a;两个人玩游戏&#xff0c;通过轮流填数字&#xff08;0~9&#xff09;&#xff0c;若最终左右两边的和相等&#xff0c;后手赢&#xff0c;否则先手赢。起始有部分数字和空格。 官方题解&#xff1a; 题解翻译&#xff1a; 让我们把余额表示为左半部分数字和…

[设计模式]合成复用原则

合成复用原则:继承和组合&#xff0c;优先使用组合。 这样写&#xff0c;每开一种车&#xff0c;就要弄一个新的Person类。 代码如下: #include <iostream> using namespace std;class AbstractCar { public:virtual void run() 0; };class DaZhong :public AbstractC…

帮 vs2019 找回丢失的 SDK

缘起 前一段时间&#xff0c;有网友遇到一个奇怪的问题&#xff0c;说他机器上的 vs2019 编译 C 工程报错。我当时一听就有两个怀疑&#xff1a;工程设置不对。vs2019 没装好。因为新建一个最简单的工程&#xff0c;编译也报一样的错误&#xff0c;所以可以排除工程设置的问题了…

java keysetview,Set——你真的了解吗?

JAVA 基础 &#xff1a;Set——你真的了解吗&#xff1f;简述Set 继承于 Collection &#xff0c;是一种集合。有元素无序、值不重复、不允许空值得特性。主要有HashSet、TreeSet两种实现方式。由于Set主要基于Map实现&#xff0c;所以特点也由Map决定。Set 结构图例如 HashSet…

Minimizing Difference CodeForces - 1244E(贪心题)

题目题意官方题解&#xff1a;百度翻译思路ac代码题意 给出一列数&#xff0c;至多n个操作使其中的数1或-1&#xff0c;要求得到最小的差值&#xff08;最大值-最小值&#xff09;&#xff1b; You are given a sequence a1_{1}1​,a2_{2}2​,…,an_{n}n​ consisting of nn …

[设计模式]依赖倒转原则

代码如下: #include <iostream> #include <string>using namespace std;//银行工作人员 class BankWorker { public:void saveService(){cout << "办理存款业务" << endl;}void payService(){cout << "办理支付业务" <&…

使用 Docker 搭建 PostgreSQL 12 主从环境

环境准备&#xff1a;一台安装了Docker的Linux服务器。为了简化演示环境&#xff0c;这里只用一台服务器来演示&#xff0c;通过不同端口来区分。01—创建一个docker bridge 网路用于测试docker network create --subnet172.18.0.0/24 dockernetwork docker network ls设置了网…