流状态计算：累计总和

Question

假设我有一个Java
IntStream，是否可以将其转换为具有累积总和的IntStream？例如，以[4、2、6，…]开头的流应转换为[4、6、12，…]。

更笼统地说，应该如何实施有状态流操作？感觉这应该可行：

myIntStream.map(new Function<Integer, Integer> {
    int sum = 0; 
    Integer apply(Integer value){ 
        return sum += value; 
    }
);

有一个明显的限制，即它仅适用于顺序流。但是，Stream.map明确需要无状态映射函数。我是否错过了Stream.statefulMap或Stream.cumulative操作，还是错过了Java流的要点？

例如，与Haskell进行比较，其中scanl1函数完全可以解决此示例：

scanl1 (+) [1 2 3 4] = [1 3 6 10]

Answer 1

您可以使用原子序号执行此操作。例如：

import java.util.concurrent.atomic.AtomicLong;
import java.util.stream.IntStream;
import java.util.stream.LongStream;

public class Accumulator {
    public static LongStream toCumulativeSumStream(IntStream ints){
        AtomicLong sum = new AtomicLong(0);
        return ints.sequential().mapToLong(sum::addAndGet);
    }

    public static void main(String[] args){
        LongStream sums = Accumulator.toCumulativeSumStream(IntStream.range(1, 5));
        sums.forEachOrdered(System.out::println);
    }
}

输出：

1
3
6
10

我使用Long来存储总和，因为两个int相加的总和完全有可能Integer.MAX_VALUE，而long的溢出几率较小。