一尘不染

Java从流中收集连续对

java

鉴于流,例如{ 0, 1, 2, 3, 4 }

如何最优雅地将其转换为给定形式:

{ new Pair(0, 1), new Pair(1, 2), new Pair(2, 3), new Pair(3, 4) }

(当然,假设我已经定义了Pair类)?

编辑:这不严格有关整数或原始流。对于任何类型的流,答案应该是通用的。


阅读 308

收藏
2020-03-04

共1个答案

一尘不染

我的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基准,我们可以使用不同的方法找到所有输入值在一个较大值之前的值(请参阅此问题)。

2020-03-04