Java 中有了Iterator为什么还需要Spliterator,聊聊Spliterator
yuyutoo 2025-03-24 22:22 5 浏览 0 评论
我们将研究Java spliterator。Java 8 中引入了spliterator。我们将研究Java中spliterator的不同方法,以及如何在Java 8中创建自定义spliterator。
介绍
Spliterator(splitable iterator可分割迭代器)接口是Java为了并行遍历数据源中的元素而设计的迭代器,这个可以类比最早Java提供的顺序遍历迭代器Iterator,但一个是顺序遍历,一个是并行遍历。
为什么有了Iterator还需要spliterator呢
从最早Java提供顺序遍历迭代器Iterator时,那个时候还是单核时代,但现在多核时代下,顺序遍历已经不能满足需求了,如何把多个任务分配到不同核上并行执行,才是能最大发挥多核的能力,所以Spliterator应运而生啦
Java 8 and Stream API 中的 Spliterator
Spliterator 在java 8中引入,在 “java.util”包中。可以看出此接口,是当作工具类引入。Spliterator 与Collection ,Stream API 结合使用,可以使用并发的方式来处理数据,提升执行速度。
请注意,分隔符支持并行处理,但不提供并行处理。我们可以使用fork / join与splitter来创建并行性。此外,分隔符也不依赖于fork / join,我们仅将其用于实现并行处理。Spliterator也可以Iterator一样进行顺序遍历。
可以简单的理解为,淘宝可以提供商品交易,但淘宝并没有商品,需要商家自行解决。
所以 BaseStream中包含一个spliterator()方法
spliterator()方法返回一个分隔符。一旦获得了Spliterator对象,就可以对其执行不同的操作。与流类似,集合类还引入了一种新的方法来初始化Java 8中的spliterator:
此方法在集合的元素上返回一个spliterator。
Spliterator 常用函数
Characteristics
函数定义为int characteristics(),此方法返回此分隔符及其元素的一组特征。它可以是以下8个值中的任何一个。以下所有值都是静态最终整数值:
- ORDERED:此值用于表示为分隔符元素定义了遇到顺序。
- DISTINCT:此值表示元素遇到的每对元素是否相等。如果我们从集合创建分离器,它将始终是DISTINCT。
- IMMUTABLE:此值表示是否无法修改元素的来源,即我们不能添加,替换或删除任何元素。
- NONNULL:此值表示遇到的元素不会为空。
- SIZED:表示estimateSize()方法返回的值表示有限大小。
- SORTED:表示该元素总是有序。
- SUBSIZED:表示由返回的所有分隔符trySplit()将为 SIZED和SUBSIZED。
- CONCURRENT:表示可以同时修改源,即,我们可以使用多个线程并发地添加,删除或删除元素,而无需同步。
hasCharacteristics()函数
定义格式
boolean hasCharacteristics(int characteristics)
characteristics()上面已经解释过的方法用于找出分离器的特性。
hasCharacteristics用于检查分隔符是否包含所有特征。
它返回一个布尔值。'true'如果分隔符中存在所有特征,否则返回false。
tryAdvance
遍历源元素。
它返回一个布尔值,并以一个Consumer作为参数。如果存在任何元素,它将执行我们传递的Consumer作为参数,并返回'true'并移至下一个元素。如果遍历所有元素,则返回'false'。例如:
运行结果,输出a 1 b 2 c 3. 在这里,我们创建了一个带有三个字符串值的ArrayList。这是一个集合变量。因此,我们已使用该spliterator()方法从中创建一个Spliterator。我们使用while循环来检查的当前返回值是否tryAdvance为true。如果为true,则在while条件内打印当前值。while循环的主体为空,我们可以将其用于其他任何操作.
trySplit 函数
在可能并行的操作中使用。
如果我们调用trySplit一个分隔符,它将返回一个分隔符,其中包含调用方分隔符不会覆盖的元素。这就是说,我们用它将分离器分成多个部分。这样做的主要好处trySplit是我们可以并行处理分割的元素。trySplit如果源包含有限数量的元素,则重复调用将返回null
实例:
运行结果
正如预期,每个Spliterator中都有不同的字符。
EstimateSize()函数
返回元素总数的估计值。返回值的类型为long。
forEachRemaining
能够将Iterator中迭代剩余的元素传递给一个函数
自定义Java Spliterator
说明:
- 自定义实现Spliterator。
- 重写4个方法 tryAdvance, trySplit, estimateSize和characteristics。
- tryAdvance函数:如果当前长度大于0,则在由startIndex定义的当前方法上调用“ accept”函数
- trySplit:根据endIndex,startIndex 两个值拆分 userrList列表。
- estimateSize:被返回列表studentList的大小。
- characteristics:返回NONNULL,即所有元素均为nonnull。
第一条和第二条语句用于创建一个并行流并找出所有User对象的age。同样,第三和第四条语句用于创建一个顺序流和所有User对象的总age。
为什么要自定义Spliterator呢?
可以按顺序或并行方式对流使用Spliterator。
总结
在本文中,我们看到了Java Spliterator的不同功能。我们还看到了Java Spliterator的使用场景。
相关推荐
- ETCD 故障恢复(etc常见故障)
-
概述Kubernetes集群外部ETCD节点故障,导致kube-apiserver无法启动。...
- 在Ubuntu 16.04 LTS服务器上安装FreeRADIUS和Daloradius的方法
-
FreeRADIUS为AAARadiusLinux下开源解决方案,DaloRadius为图形化web管理工具。...
- 如何排查服务器被黑客入侵的迹象(黑客 抓取服务器数据)
-
---排查服务器是否被黑客入侵需要系统性地检查多个关键点,以下是一份详细的排查指南,包含具体命令、工具和应对策略:---###**一、快速初步检查**####1.**检查异常登录记录**...
- 使用 Fail Ban 日志分析 SSH 攻击行为
-
通过分析`fail2ban`日志可以识别和应对SSH暴力破解等攻击行为。以下是详细的操作流程和关键分析方法:---###**一、Fail2ban日志位置**Fail2ban的日志路径因系统配置...
- 《5 个实用技巧,提升你的服务器安全性,避免被黑客盯上!》
-
服务器的安全性至关重要,特别是在如今网络攻击频繁的情况下。如果你的服务器存在漏洞,黑客可能会利用这些漏洞进行攻击,甚至窃取数据。今天我们就来聊聊5个实用技巧,帮助你提升服务器的安全性,让你的系统更...
- 聊聊Spring AI Alibaba的YuQueDocumentReader
-
序本文主要研究一下SpringAIAlibaba的YuQueDocumentReaderYuQueDocumentReader...
- Mac Docker环境,利用Canal实现MySQL同步ES
-
Canal的使用使用docker环境安装mysql、canal、elasticsearch,基于binlog利用canal实现mysql的数据同步到elasticsearch中,并在springboo...
- RustDesk:开源远程控制工具的技术架构与全场景部署实战
-
一、开源远程控制领域的革新者1.1行业痛点与解决方案...
- 长安汽车一代CS75Plus2020款安装高德地图7.5
-
不用破解原车机,一代CS75Plus2020款,安装车机版高德地图7.5,有红绿灯读秒!废话不多讲,安装步骤如下:一、在拨号状态输入:在电话拨号界面,输入:*#518200#*(进入安卓设置界面,...
- Zookeeper使用详解之常见操作篇(zookeeper ui)
-
一、Zookeeper的数据结构对于ZooKeeper而言,其存储结构类似于文件系统,也是一个树形目录服务,并通过Key-Value键值对的形式进行数据存储。其中,Key由斜线间隔的路径元素构成。对...
- zk源码—4.会话的实现原理一(会话层的基本功能是什么)
-
大纲1.创建会话...
- Zookeeper 可观测性最佳实践(zookeeper能够确保)
-
Zookeeper介绍ZooKeeper是一个开源的分布式协调服务,用于管理和协调分布式系统中的节点。它提供了一种高效、可靠的方式来解决分布式系统中的常见问题,如数据同步、配置管理、命名服务和集群...
- 服务器密码错误被锁定怎么解决(服务器密码错几次锁)
-
#服务器密码错误被锁定解决方案当服务器因多次密码错误导致账户被锁定时,可以按照以下步骤进行排查和解决:##一、确认锁定状态###1.检查账户锁定状态(Linux)```bash#查看账户锁定...
- zk基础—4.zk实现分布式功能(分布式zk的使用)
-
大纲1.zk实现数据发布订阅...
- 《死神魂魄觉醒》卡死问题终极解决方案:从原理到实战的深度解析
-
在《死神魂魄觉醒》的斩魄刀交锋中,游戏卡死犹如突现的虚圈屏障,阻断玩家与尸魂界的连接。本文将从技术架构、解决方案、预防策略三个维度,深度剖析卡死问题的成因与应对之策,助力玩家突破次元壁障,畅享灵魂共鸣...
你 发表评论:
欢迎- 一周热门
-
-
前端面试:iframe 的优缺点? iframe有那些缺点
-
带斜线的表头制作好了,如何填充内容?这几种方法你更喜欢哪个?
-
漫学笔记之PHP.ini常用的配置信息
-
推荐7个模板代码和其他游戏源码下载的网址
-
其实模版网站在开发工作中很重要,推荐几个参考站给大家
-
[干货] JAVA - JVM - 2 内存两分 [干货]+java+-+jvm+-+2+内存两分吗
-
正在学习使用python搭建自动化测试框架?这个系统包你可能会用到
-
织梦(Dedecms)建站教程 织梦建站详细步骤
-
【开源分享】2024PHP在线客服系统源码(搭建教程+终身使用)
-
2024PHP在线客服系统源码+完全开源 带详细搭建教程
-
- 最近发表
-
- ETCD 故障恢复(etc常见故障)
- 在Ubuntu 16.04 LTS服务器上安装FreeRADIUS和Daloradius的方法
- 如何排查服务器被黑客入侵的迹象(黑客 抓取服务器数据)
- 使用 Fail Ban 日志分析 SSH 攻击行为
- 《5 个实用技巧,提升你的服务器安全性,避免被黑客盯上!》
- 聊聊Spring AI Alibaba的YuQueDocumentReader
- Mac Docker环境,利用Canal实现MySQL同步ES
- RustDesk:开源远程控制工具的技术架构与全场景部署实战
- 长安汽车一代CS75Plus2020款安装高德地图7.5
- Zookeeper使用详解之常见操作篇(zookeeper ui)
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)