首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Java 中有Iterator,为什么还需要Spliterator

我们将研究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:

default Spliterator 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的使用场景。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20191103A0E2ZQ00?refer=cp_1026
  • 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 cloudcommunity@tencent.com 删除。

扫码

添加站长 进交流群

领取专属 10元无门槛券

私享最新 技术干货

扫码加入开发者社群
领券