在Java的流中,Haskell的scanl相当于什么？

当这个问题要求python时,在Java的流中Haskell的scanl相当于什么？

到目前为止我提出的最好的是使用

reduce(identity, accumulator, combiner)

使用累加器保存最新结果并将结果累积到列表中,尽管可能不会使用组合器.我也不确定如何防止它并行使用,它不起作用.

也许Stream是(相当于)scanl的错误接口？

1> Tagir Valeev..：

---

看起来标准的Stream API没有scanl等价物.其中一个原因是scanl严格从左到右的操作,这使得很难从并行处理中获益(并行处理是Stream API的一个重要部分).但是,您可以使用第三方库,例如我的免费StreamEx库.它扩展了标准的Stream API,增加了许多有用的功能,包括scanLeft:

List list = IntStreamEx.range(10).boxed().scanLeft(Integer::sum);
System.out.println(list);
// outputs [0, 1, 3, 6, 10, 15, 21, 28, 36, 45]

scanLeft即使使用并行流,此操作也可以保证工作,但除非您有一些可以并行化的计算密集型上游操作,否则您不太可能获得加速.

---

我知道OP要求流,但如果你正在使用数组,你也可以考虑`Arrays.parallelPrefix`; 例如`Arrays.parallelPrefix(arr,Integer :: sum);`.这不是一个严格的扫描,因为我认为它需要初始值和二元运算符,但是......

---

@AlexisC.是的,这是一个很好的补充(考虑写下你的答案!).但是应该注意`parallelPrefix`需要一个像`reduce`这样的关联函数.