Java从流中收集连续对

Java从流中收集连续对

我的StreamEx库扩展了标准流，它pairMap为所有流类型提供了一种方法。对于原始流，它不会更改流类型，但可用于进行一些计算。最常见的用法是计算差异：

int[] pairwiseDiffs = IntStreamEx.of(input).pairMap((a, b) -> (b-a)).toArray();

对于对象流，你可以创建任何其他对象类型。我的库没有提供任何新的用户可见的数据结构

Pair

（这是库概念的一部分）。但是，如果你有自己的

Pair

类并想使用它，则可以执行以下 *** 作：

Stream<Pair> pairs = IntStreamEx.of(input).boxed().pairMap(Pair::new);

或者，如果你已经有一些Stream：

Stream<Pair> pairs = StreamEx.of(stream).pairMap(Pair::new);

此功能是使用自定义分隔符实现的。它的开销很低，可以很好地并行化。当然，它可以与任何流源一起使用，而不仅仅是像许多其他解决方案一样随机访问列表/数组。在许多测试中，它的表现都非常好。这是一个JMH基准，我们可以使用不同的方法找到所有输入值在一个较大值之前的值（请参阅此问题）。