- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我尝试使用 Java Streams 并行化一些工作。让我们考虑这个简单的例子:
Stream.generate(new Supplier<Integer>() {
@Override
public Integer get() {
return generateNewInteger();
}
})
.parallel()
.forEachOrdered(new Consumer<Integer>() {
@Override
public void accept(Integer integer) {
System.out.println(integer);
}
});
问题是它不会为forEachOrdered
调用accept
方法,它只有在我使用forEach
时才有效。我想问题是 Stream.generate
在内部创建了 InfiniteSupplyingSpliterator
,它没有 ORDERED
特性。
问题是为什么?似乎我们知道数据生成的顺序。第二个问题是如何在生成流元素的并行流上执行forEachOrdered
?
最佳答案
最简单的答案是,Stream.generate
是无序的,因为 it’s specification这么说。
这并不是说如果实现尽可能按顺序处理项目,实际上恰恰相反。一旦一个操作被定义为无序的,只要有可能,实现就会尝试从无序的本质中获益。如果您在无序操作中遇到看起来像源顺序的事情,则可能没有办法从无序处理中获益,或者实现尚未使用所有机会。由于这可能会在未来版本或替代实现中发生变化,因此如果操作已指定为无序,则您不得依赖该顺序。
与有序的 Stream.iterate
相比,将 Stream.generate
定义为无序的意图可能会变得更加清晰。传递给 iterate
的函数将接收其前一个元素,因此元素之间存在前-后关系,因此是一种排序。通过 Stream.generate
的供应商没有收到前一个元素,换句话说,仅考虑功能签名时,与前一个元素没有关系。这适用于 Stream.generate(() -> constant)
或 Stream.generate(Type::new)
之类的用例,但不适用于 Stream.generate (instance::statefulOp)
,这似乎不是预期的主要用例。如果操作是线程安全的并且您可以接受流的无序性质,它仍然有效。
你的例子一直没有进展的原因是 forEachOrdered
的实现实际上没有考虑无序性,而是尝试按照遇到顺序拆分后的 block 进行处理,即所有子-任务尝试缓冲它们的元素,以便一旦它们左侧的子任务完成,它们就可以将它们传递给操作。当然,缓冲和无限源不能一起很好地发挥作用,尤其是因为底层 InfiniteSupplyingSpliterator
将拆分为自己无限的子任务。原则上,有一个最左边的任务可以将其元素直接提供给操作,但该任务似乎在队列中的某个位置,等待被激活,这永远不会发生,因为所有工作线程都已经忙于处理另一个无限子-任务。最终,如果您让它运行足够长的时间,整个操作将因 OutOfMemoryError
而中断……
关于java - 为什么 Java Stream 生成器是无序的?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42490328/
我使用以下代码和嵌套生成器迭代文本文档并使用 get_train_minibatch() 返回训练示例。我想保留( pickle )生成器,这样我就可以回到文本文档中的相同位置。但是,您不能 pick
在本教程中,您将借助示例了解 JavaScript 生成器。在 JavaScript 中,生成器提供了一种使用函数和迭代器的新方法。 使用生成器, 您可以从函数内部的任何位置停止执行函数 并从
LESS is very cool .我一直想知道是否有任何好的 html 生成器可以让我更轻松地编写表单或做其他事情。除了 html,是否有一些类似的东西? 最佳答案 已尝试 Haml ? 从它的网
前言 如果是做python或者其他语言的小伙伴,对于生成器应该不陌生。但很多php开发者或许都不知道生成器这个功能,可能是因为生成器是php 5.5.0才引入的功能,也可以是生成器作用不是很明显。
我正在尝试编写一个使用生成器语法生成日期时间列表的函数: let dateRange = let endDate = System.DateTime.Parse("6/1/2010")
我遇到了一些看起来像的代码: [func(val) for val in iterable] 有一个可迭代对象(在我的例子中是一个生成器),用户想要为其副作用调用每个值的函数(例如 func 可以只是
Delphi 有内置的东西来生成 UUID 吗? 最佳答案 program Guid; {$APPTYPE CONSOLE} uses SysUtils; var Uid: TGuid; Result
我正在深入研究 javascript 生成器,但我真的很困惑。 我使用 node@0.11.x 运行此示例: function find() { process.nextTick(functi
有人知道一些关于如何为 hibernate 创建自定义 ID 生成器的好教程吗? 最佳答案 在 Google 上粗略搜索“hibernate 自定义 id 生成器教程”发现了以下可能性。我排除了那些看
我正在关注 Python 大师 David Beazley 的幻灯片。它指出“生成器也用于并发。这是一个示例: from collections import deque def countdown(
我有一个生成事件的生成器,我想用可以从 API 获取的附加元数据来丰富它。 某些事件具有与其链接的对象 ID,而其他事件则具有对象的哈希值,但不能同时具有两者。我无法根据哈希获取对象 id,我只能执行
假设我有一个自定义类: public class CustomClass { private String name; private String data; public
我正在考虑实现一个函数来在 SQL 请求中“构建”WHERE 子句,如下所示: "SELECT * FROM table $where" 使用如下所示的循环构建 $where: $arr=array(
我正在寻找执行此操作的标准函数: def Forever(v): while True: yield v 这看起来太琐碎了,我不敢相信没有标准版本。 就此而言,有人知道指向所有标准生成器函
我知道这个网站上有几个非常相似的相关问题,但是在看了这部剧之后,我相信这个问题本身就是独一无二的。如果有人能找到并提供证据证明我的问题完全被骗了,我会自己撤回它(所以请不要否决这个!)。 我是 Jav
void __fastcall TForm1::Button1Click(TObject *Sender) { int size = MemoEnter->GetTextLen() + 1;
按照目前的情况,这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持,但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visit the
我试图在我的生成器的以下两个定义之间做出决定。哪个更好?哪个“更像 python ”?无论如何,有没有办法减轻每一个的缺点? def myGenerator1(howMany): result
我有一个 Python 生成器 lexg,它在每次迭代时生成一个列表。该代码似乎在传统的 for 循环意义上工作,即 for i in lexg(2,2): print(i) 产生: [2, 0] [
我希望这不会超出 Python 生成器的能力,但我想构建一个这样,每次调用该函数时,它都会返回下一分钟直到结束时间。 因此该函数读取开始时间和结束时间,并以分钟为单位返回时间,直到涵盖其间的所有时间。
我是一名优秀的程序员,十分优秀!