当前位置:首页 > 每日看点 > 正文内容

如何理解ja8中stream的延迟作的意思?

卡卷网7个月前 (01-10)每日看点130

你贴出来的解释已经很清晰了:

    只有当一个<>终端作被调用时,例如forEach()collect()reduce()等,Stream管道(pipeline)才会被<>启动<>只遍历一次数据源完成所有指定的作

这里不直接解释什么是延迟作(LazyEvaluation),咱们边写边聊。

<>最终的目的:写出一个大致符合上面<>两点要求的SimpleStream(仿Ja8StreamAPI)

手写Stream版本1

在filter执行时,打印:element+_filter

很简单,应该都能看懂。然后给上面的Stream写一个:

故意把filter和forEach拆成两段代码

在终端作forEach执行前,调用filter时已经开始处理元素了,不符合文章最开始定义的第一条:终端作调用时才启动。

手写Stream版本2

版本2版本1更好理解,而且效果也更好。同样的案例,得到的结果是:

版本2符合第一点定义(其实也符合第二点定义)。

手写Stream版本3

如果再来一个map(),难道要这样?

再来一个peek()呢?再定一个变量保存peek作?很显然,<>为每一种作定义一个变量来存储的做法是不可行的。

代码迭代到这,从面向对象的角度,一般会倾向于抽象。同为中间作,filter看起来和map有很大的不同,如果把peek也算进来,可的算是一锅乱炖:

    filter:接受一个item,返回ooleanmap:接受一个item,返回另一个类型的itempeek:接受一个item,做一些作,不返回

返回值完全不同,甚至有些作没有返回值,似乎不好做函数抽象。但是换个角度,这些中间作就像一节节下水管道,水至上而下流过,只有两种可能:

    流不下来(蒸发了)流下来了(不管发生了什么化学反应,变成了什么)

所以,这里打算抽象出一个Stage。

privateinteceStage{ Ojectaccept(Ojectitem); }

为了简单起见,就不整泛型了,看着烦。

FilterStage和MapStage长啥样呢?

很简单对吧,Stage也没什么大不了的,<>就是把predicate和mapper包一下,不管内地的、的、的,纵然有这样或那样的不同,都是中国人对吧。用一个更大的抽象概念,去求同存异即可。

既然都是Stage,自然就可以用List<Stage>去<>一存储所有中间作。

重点看forEach:遍历每一个元素,为每个元素先执行中间作、再执行终端作,如果没有终端作,中间作不会启动(只是被存起来而已)。

至此,开头定义的第一、第二点都符合了。再来一把:

李健被filter了,所以没有后续作。元素也确实是逐个执行,并且仅遍历一次。

手写Stream版本4

为了稍微接近Ja8的StreamAPI,这里再迭代:优化forEach中的process。

process的逻辑是,对当前遍历到的元素,逐个执行所有中间作,内部用的是for循环。现在我要把它改成一种类似<>链式结构,你也可以叫它责任链,anyway。

怎么引入链式结构呢?这取决于你期望借助链式结构达到什么效果。

如,我期望最终的写法是这样的:

先别管Sink是什么,你可以把它看作另一种Stage,也是对中间作的封装。总之,通过wrapStages(),我们得到了一种链式结构,这条链上有我们通过filter()、map()等方法压入的中间作,<>只要调用sink.accept(element),element就会沿着链条执行下去,就像往下水道倒了一碗水。

开始实施。

目前:stage负责<>封装中间作

目标

    stage:组装链式结构sink:<>封装中间作、当前作执行结束后,<>将流程推向下一个

发现了吗,原本stage的职责转移给了sink,它有了新的职责:组装链式结构。

链式结构怎么来的

filter()、map()这些方法只负责存储predicate等作、不涉及组装,等到forEach触发后才会调用wrapStages()组装链式结构。

第10行:stage.wrap(sink)是核心逻辑

以filterStage为例:

newNode=wrap(oldNode)

也就是说,wrap干了两件事:

    创建并返回新节点通过闭包,在新节点内部维持对旧节点的引用
      forEachfilter->forEachmap->filter->forEach

链式作如何执行

调用forEach开启管道作:

pulicvoidforEach(Consumer<?superT>action){ Sinksink=wrapStages(newForEachSink<>(action)); for(Telement:soce){ //上面组装成功后,开始遍历元素:把元素倒入下水道 sink.accept(element); } }

accept是管道作的入口,从filter开始:

代码已上传到git仓库:com/ro/advanced/fluent/stream2

ro1988/design-pattern

对设计模式、Ja进阶感兴趣,可以参考以下路线。

ro1988:Ja程序员练级路线

扫描二维码推送至手机访问。

版权声明:本文由卡卷网发布,如需转载请注明出处。

本文链接:https://www.kajuan.net/ttnews/2025/01/8449.html

分享给朋友:

相关文章

网页上的视频怎么下载呀?

网页上的视频怎么下载呀?

1、贝贝BiliBili - B站视频下载https://xbeibeix.com/api/bilibili/贝贝BiliBili 是个免费、免登录的bilibili视频下载工具,没有任何套路。把视频链接粘贴进去 → 输入验证码 → 解析视...

想要在双 11 换一台全面无短板的新手机,有没有「闭眼买」的机型推荐?

想要在双 11 换一台全面无短板的新手机,有没有「闭眼买」的机型推荐?

最近一个月各大手机厂商的旗舰机扎堆发布,不知道大家看爽了没?这一代的性能续航大提升,最低 3599 元就能买到,同时老款也有不小的降幅,今年双 11 算是相当适合换手机的节点了!这次,小黑就给大家推荐双 11 期间值得购买的手机...150...

台积电通知其中国客户,从下周开始,所有 7nm 及以下芯片出货将停止。如何看待这一行为?

台积电通知其中国客户,从下周开始,所有 7nm 及以下芯片出货将停止。如何看待这一行为?

我说美国快要没招了,你信么?这次台积电宣布停止向中国大陆客户供应7纳米及更先进AI芯片,再加上前段时间台积电对华为的制裁,我们基本可以认为,台积电在高端芯片领域,已经彻底把大陆给拉黑了,这也意味着中美芯片战已经到了最关键的时刻,一旦我们克服...

有没有高手指点一下Google做SEO现在的技巧啊?心好累。

有没有高手指点一下Google做SEO现在的技巧啊?心好累。

搜索引擎优化 (SEO) 的目标是让 Google 在用户输入相关搜索查询时提供您的网页链接。虽然没有固定的蓝图可以保证您获得最高排名,但有几种 SEO 最佳实践(您可以将其视为 SEO 规则)可以增加您在非付费结果中获得良好排名的机会。谷...

有没有能够兼顾便携并且流畅运行各种AI应用的笔记本?求推荐?

有没有能够兼顾便携并且流畅运行各种AI应用的笔记本?求推荐?

看了下题主的描述,可以考虑「联想YOGA Air 15 Aura AI元启版」,今年9月底出的一款轻薄本,也通过了英特尔Evo严苛认证。处理器用了英特尔最新的「酷睿 Ultra 7 258V」,主要亮点就是AI性能、图形处理能力和能效,很适...

有哪些让你目瞪口呆的 Bug ?

有哪些让你目瞪口呆的 Bug ?

成都有个监狱情况比较特殊,关押的基本全是重犯,而且还都是经济犯和政治犯,他们以前都是一方大佬,在自己的一亩三分地翻手为云覆手为雨,无非是不小心中箭落马或帮老大顶锅才进监狱,所以即使进来了,他们依然保持着体面和骄傲,依从性差,虽然不至于和监狱...

发表评论

访客

看不清,换一张

◎欢迎参与讨论,请在这里发表您的看法和观点。