java -- stream流

news2024/12/23 12:35:44
写在前面:
stream流一直在使用,但是感觉还不够精通,现在深入研究一下。 stream这个章节中,会用到

函数式接口–lambda表达式–方法引用的相关知识

介绍

是jdk8引进的新特性。
stream流是类似一条流水线一样的操作,每次对数据进行一个操作。
可以简化操作
我觉得还是以官方文档来说比较好

官方介绍

部分分散到后面去了,有的我用我自己的话换了一下

初步介绍

支持顺序和并行聚合操作的元素序列。以下示例说明了使用 和 IntStream的Stream聚合操作:

int sum = widgets.stream() 
                  .filter(w -> w.getColor() == RED)
                   .mapToInt(w -> w.getWeight())
                  .sum();

在此示例中, widgets是一个单列集合。我们通过创建一个Collection.stream()对象流,过滤它以生成仅包含红色小部件的流 Widget,然后将其转换为代表每个红色小部件权重的值流 int。然后将此流相加以生成总重量。

流的组成

为了执行计算,流操作被组合到流管道中。
流管道组成:

  1. 源(可能是数组、集合、生成器函数、I/O 通道等)
  2. 零个或多个中间操作
  3. 一个终端操作组成。
    流是懒惰的;仅在启动终端操作时对源数据执行计算,并且仅在需要时使用源元素。

实现

没看懂
流实现在优化结果计算方面允许很大的自由度。例如,流实现可以自由地从流管道中执行操作(或整个阶段),因此可以免除行为参数的调用,如果它可以证明它不会影响计算结果。这意味着行为参数的副作用可能并不总是被执行,也不应该被依赖,除非另有规定(例如通过终端操作 forEach 和 forEachOrdered)。

和集合的区别

集合和流虽然具有一些表面上的相似之处,但具有不同的目标。
流主要关注其元素的有效管理和访问。相比之不提供直接访问或操作其元素的方法,而是关注以声明方式描述其源以及将在该源上聚合执行的计算操作。但是,如果提供的流操作不提供所需的功能,则和 iterator() spliterator() 操作可用于执行受控遍历。

并发

流管道可以被视为对流源的查询。除非源明确设计为并发修改(例如 ConcurrentHashMap),否则在查询流源时修改流源可能会导致不可预测或错误的行为。
除了明确说可以修改的,一般都可以对其进行修改,向迭代器一样,下面是对上面的解释
大多数流操作接受描述用户指定行为的参数,例如在上面的示例中传递给 mapToInt的 lambda 表达式 w -> w.getWeight()。为了保持正确的行为,这些行为参数:
必须是非干扰的(它们不修改流源);和
在大多数情况下,必须是无状态的(其结果不应依赖于在流管道执行期间可能更改的任何 状态 )。

参数

此类参数始终是函数接口(如 Function)的实例,并且通常是 lambda 表达式或方法引用。除非另有指定,否则这些参数必须为非空值。
一个流只能操作一次(调用中间流或终端流操作)。
不可用重复操作,stream对象不可用第二次,所以我们一般使用链式编程。
例如,这排除了“分叉”流,其中同一源馈送两个或多个管道,或同一流的多个遍历。如果流实现检测到流正在重用,则可能会引发 IllegalStateException 。但是,由于某些流操作可能会返回其接收器而不是新的流对象,因此可能无法在所有情况下都检测到重用。

最后

流有一个 close() 方法并实现 AutoCloseable.在流关闭后对其进行操作将引发 IllegalStateException。
自动关闭
大多数流实例在使用后实际上并不需要关闭,因为它们由集合、数组或生成函数支持,不需要特殊的资源管理。通常,只有源为 IO 通道的流(例如 返回 Files.lines(Path)的流)才需要关闭。如果流确实需要关闭,则必须在 try-with-resources 语句或类似控制结构中将其作为资源打开,以确保在其操作完成后立即关闭它。
流管道可以按顺序或并行执行。此执行模式是流的属性。流是通过顺序执行或并行执行的初始选择创建的。
(例如,创建一个顺序流, Collection.stream() 并 Collection.parallelStream() 创建一个并行流。这种执行模式的选择可以由 or sequential() parallel() 方法修改,也可以用该方法 isParallel() 查询。

获取stream流

双列集合是不可用直接获取的。

数据类型获取方法
数组Arrays.stream(数组);
单列集合直接调用Collection的stream方法
双列集合转换为单列在获取,如keyset/entryset
零散数据stream.of(T…values);

数组
在这里插入图片描述
单列集合
在这里插入图片描述
双列集合
在这里插入图片描述
零散数据
不过不理解为什么不是一个类型也可以
在这里插入图片描述
在这里插入图片描述
获取其class对象,发现就是不同类型
在这里插入图片描述

除了 Stream对象引用流之外,还有LongStream和 的IntStream原始专用化,所有这些都称为“流”,并符合此处描述的特征和DoubleStream限制。
那么如果固定类型的话
选取固定的stream来进行封装

在这里插入图片描述

方法

中间方法

filter

过滤,只保留符合条件的数据
Stream<T> filter(Predicate<? super T> predicate);

在这里插入图片描述

limit

限制流元素的大小
在这里插入图片描述

skip

舍弃前面的n个元素,如果少于n则返回空流
在这里插入图片描述
limit和skip可以组合使用,获取n-maxsize中的元素

distinct

去重,依靠hashcode和equals
在这里插入图片描述
依靠hashset去重
在这里插入图片描述

concat

将2个流合成一个
静态方法,需要类名调用

在这里插入图片描述

map

类型转换/对每一个进行操作
在这里插入图片描述
类型转换,T和R类型不相同
如果只是操作则T和R类型相同
在这里插入图片描述
同类型的

Stream.of(2,3,4,5,6,7,8,9)
                .map(i -> i++).forEach(System.out::println);

在这里插入图片描述
在这里插入图片描述

不同类型
在这里插入图片描述

终结方法

forEach

遍历,这个上面用过了

void forEach(Consumer<? super T> action);

count

返回此流中的元素计数

long count = Stream.of(2, 3, 4, 5, 6, 7, 8, 9)
                .map(i -> i++).count();
        System.out.println(count);

在这里插入图片描述

toArray

在这里插入图片描述

        Object[] array =Stream.of(2, 3, 4, 5, 6, 7, 8, 9)
                .map(i -> i++).toArray();
        System.out.println(Arrays.toString(array));
        Integer[] arr = Stream.of(2, 3, 4, 5, 6, 7, 8, 9)
                .map(i -> i++).toArray(Integer[]::new);
        System.out.println(Arrays.toString(arr));

在这里插入图片描述

collect

收集成集合,如set,list,map

list

        List<Integer> list = Stream.of(2, 3, 4, 5, 6, 7, 8, 9)
                .filter(s -> s % 2 == 0)
                .collect(Collectors.toList());
         Assert.assertEquals(list,List.of(2,4,6,8));

set

        Set<Integer> set = Stream.of(2, 3, 4, 5, 6, 7, 8, 9)
                .filter(s -> s % 2 == 0)
                .collect(Collectors.toSet());
        Assert.assertEquals(set,Set.of(2,4,6,8));

map

        Stream.of("zhangsan-18","lisi-20","wangwu-22")
                .map(s -> s.split("-"))
                .collect(Collectors.toMap(s -> s[0], s -> s[1]))
                .forEach((k,v) -> System.out.println(k + " : " + v));

这个代码呢,是我写完方法名和开头zhangsan自动生成的。
我开始还在疑惑,咦forEach和collect怎么可能继续用,后来我才想起,collect之后就变成Map集合了,后面这个forEach方法是map集合里面的,不是流里面的了。

测试结果,set和list通过了,map打印也正确
在这里插入图片描述

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

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

相关文章

初识HTML、W3C标准、如何利用IDEA创建HTML项目、HTML基本结构、网页基本信息

一、什么是HTML&#xff1f; HTML——Hyper Text Markup Languagr&#xff08;超文本标记语言&#xff09; 超文本包括&#xff1a;文字、图片、音频、视频、动画等 目前网页中常用——HTML5 HTML5提供了一些新的元素和一些有趣的新特性&#xff0c;同时也建立了一些新的规则…

LeetCode-1049. 最后一块石头的重量 II

目录思路回溯法动态规划动态规划(压缩)题目来源 1049. 最后一块石头的重量 II 思路 最后一块石头的重量&#xff0c;两个近似的石头值相近&#xff0c;那么最后一块石头的重量最小 举例:stones [2,7,4,1,8,1] 总和sum23&#xff0c;我们取目标值targetsum/211&#xff0c;我…

常用的密码算法有哪些?

我们将密码算法分为两大类。 对称密码&#xff08;密钥密码&#xff09;——算法只有一个密钥。如果多个参与者都知道该密钥&#xff0c;该密钥 也称为共享密钥。非对称密码&#xff08;公钥密码&#xff09;——参与者对密钥的可见性是非对称的。例如&#xff0c;一些参与者仅…

[牛客]链表中倒数第k个结点

使用快慢指针法:两种思路:1.fast先向后走k-1次,slow再向后走1次,然后fast和slow同时向后走,当fast走到最后一个结点时,slow刚好在倒数第k个位置上;2.fast先向后走k次,slow再向后走1次,然后fast和slow同时向后走,当fast走到最后一个结点的后面时(此时为NULL),slow刚好在倒数第k个…

AfxMessageBox 自定义封装

一般情况下AfxMessageBox是系统提供的一个对话框&#xff0c;若要做这种效果的&#xff0c;必须重写。 实例1&#xff1a; void test_SgxMemDialog_AutoSize() { //使用给定大小的对话框 CSgxMemDialog dlg(180, 60); dlg.SetWindowTitle(_T(" SegeX - CT&qu…

如何正确努力?7 分钟重新认识冰山模型。

我明明很努力&#xff0c;但好像没什么卵用&#xff1f;”这是很多职场人士或者即将进入职场的人容易产生的困惑。美国著名社会心理学家麦克利兰在 1973 年所提出的素质冰山模型大概能解释这种情况。不过&#xff0c;让我们先从【冰山一角】这个词开始。当你听到它&#xff0c;…

Linux基础命令-sed流编辑器

Linux三剑客-grep命令 Sed 一. 命令介绍 先到帮助文档中查看命令的描述信息 NAME sed - stream editor for filtering and transforming text sed命令是操作、过滤和转换文本内容的强大工具&#xff0c;常用功能包括结合正则表达式对文件实现快速增删改查&#xff0c;其中查询…

ChIP-seq 分析:GO 功能测试与 Motifs 分析(12)

动动发财的小手&#xff0c;点个赞吧&#xff01; 1. 包加载 我们可以使用 rGREAT 包中提供的 GREAT Bioconductor 接口。 library(rGREAT) 2. GO和功能测试 要提交作业&#xff0c;我们可以使用 Myc 峰的 GRanges 并使用 submitGreatJob 函数指定基因组。 此函数返回一个 Grea…

王道计算机组成原理课代表 - 考研计算机 第三章 存储系统 究极精华总结笔记

本篇博客是考研期间学习王道课程 传送门 的笔记&#xff0c;以及一整年里对 计算机组成 知识点的理解的总结。希望对新一届的计算机考研人提供帮助&#xff01;&#xff01;&#xff01; 关于对 存储系统 章节知识点总结的十分全面&#xff0c;涵括了《计算机组成原理》课程里…

云时代数据科学平台--Sengee

随着数字经济的步步落地&#xff0c;我们将迎来“数据风暴”的冲击&#xff0c;传统的数据处理方式已经显得跟不上脚步&#xff0c;传统的开发方式已经不足矣应对“数据风暴”带来的需求革命&#xff0c;因此&#xff0c;需要考虑开放、多元、可变、集成、易用等数据处理的属性…

【C 语言 笔记】解决控制台闪烁/鬼畜/光标乱跑问题

问题 如果你要在控制台里“画”一些频繁更新的东西&#xff0c;比如做个小游戏&#xff0c;常见的思路是&#xff1a; while(1) {//先清空system("clear");//再画printf("....."); }然后控制台的就闪个不停&#xff0c;很瞎眼。 解决 0 降低刷新频率&a…

分布式相关知识(分布式锁,事务实现方案,CAP)

一 CAP理论 1.1 CAP理论 CAP原则又称CAP定理&#xff0c;指的是在一个分布式系统中&#xff0c;Consistency&#xff08;一致性&#xff09;、 Availability&#xff08;可用性&#xff09;、Partition tolerance&#xff08;分区容错性&#xff09;这3个基本需求&#xff0…

【3维视觉】网格细分Mesh Subdivision算法介绍(Loop, Catmull-Clark, Doo-Sabin)

引言 介绍了Loop, Catmull-Clark, Doo-Sabin细分。 算法介绍 1. Loop细分 Loop细分是Charles Loop在1987年在硕士论文中提出的一种对三角网格的细分算法。 Loop细分是递归定义的&#xff0c;每一个三角形一分为四&#xff0c;对于新生成的点和旧点以不同的规则更新。 点的…

医院信息管理云平台源码 云HIS系统源码 4级电子病历系统

基层医院云HIS系统源码 高端商业his源码 有演示&#xff0c;可直接项目运营。 一款满足基层医院各类业务需要的云HIS系统。该系统能帮助基层医院完成日常各类业务&#xff0c;提供病患挂号支持、病患问诊、电子病历、开药发药、会员管理、统计查询、医生站和护士站等一系列常规…

leetcode 55. 跳跃游戏

给定一个非负整数数组 nums &#xff0c;你最初位于数组的 第一个下标 。 数组中的每个元素代表你在该位置可以跳跃的最大长度。 判断你是否能够到达最后一个下标。 示例 1&#xff1a; 输入&#xff1a;nums [2,3,1,1,4] 输出&#xff1a;true 解释&#xff1a;可以先跳 1 …

刷题记录(2023.3.6 - 2023.3.11)

我很喜欢这周的感觉&#xff0c;前两道题对着 wp 简略复现了一下&#xff0c;由于以前都是自己学习&#xff0c;对一些稍微多、稍微难的题都会马上避开&#xff0c;笨小孩逃避太久了&#xff0c;有些事逃不掉&#xff0c;总得面对&#xff0c;开始往往很难&#xff0c;多花点时…

大数据下的协调者Zookeeper详解

Zookeeper框架 为什么要学习Zookeeper框架 1、Zookeeper是作为大数据生态圈框架中非常重要的一员 2、Zookeeper单独使用没有意义&#xff0c;主要是用来管理其他框架&#xff0c;被称为动物管理员 3、后期Hadoop的高可用框架、Kafka都需要依赖ZookeeperZookeeper的概述 1、Z…

C++回顾(二十四)—— set / multiset容器

24.1 set概述 set是一个集合容器&#xff0c;其中所包含的元素是唯一的&#xff0c;集合中的元素按一定的顺序排列。元素插入过程是按排序规则插入&#xff0c;所以不能指定插入位置。set采用红黑树变体的数据结构实现&#xff0c;红黑树属于平衡二叉树。在插入操作和删除操作…

Spring——AOP核心概念和AOP入门案例

AOP:面向切面编程&#xff0c;一种编程范式&#xff0c;指导开发者如何组织程序结构 作用:在不惊动原始设计的基础上进行功能增强 Spring理念:无侵入式编程 比如测试一个方法的万次执行时间&#xff0c;原本没有Aop需要这样写 public void save() {Long stSystem.currentTim…

Java开发 - 消息队列之Kafka初体验

目录 前言 Kafka 什么是Kafka Kafka软件结构 Kafka的特点 怎么启动Kafka 下载Kafka 配置Kafka Zookeeper 启动Kafka Kafka案例 添加依赖 添加配置 配置启动类 创建生产者 创建消费者 测试 结语 前言 前几日总结了消息队列的一些知识&#xff0c;相信看完的同…