一起迭代两个 Java-8-Streams [重复]答案

【问题标题】：Iterate two Java-8-Streams together [duplicate]一起迭代两个 Java-8-Streams [重复]
【发布时间】：2014-07-26 10:12:57
【问题描述】：

我想一起迭代两个 Java-8-Stream，以便在每个迭代步骤中都有两个参数。类似的东西，somefunction 产生类似Stream<Pair<A,B>> 的东西。

Stream<A> as;
Stream<B> bs;
somefunction (as, bs)
  .forEach ((a, b) -> foo (a, b));
// or something like
somefunction (as, bs)
  .forEach ((Pair<A, B> abs) -> foo (abs.left (), abs.right ()));

我想知道，如果 Java 提供类似的东西，尽管 Java 中没有 Pair :-( 如果没有这样的 API-Function，是否有另一种同时迭代两个流的方法？

【问题讨论】：

标签： java java-8 java-stream

【解决方案1】：

static <A, B> Stream<Pair<A, B>> zip(Stream<A> as, Stream<B> bs)
{
    Iterator<A> i=as.iterator();
    return bs.filter(x->i.hasNext()).map(b->new Pair<>(i.next(), b));
}

这不提供并行执行，但原始 zip 实现也不提供。

作为F. Böller has pointed out，如果bs 是无限的而as 不是，则它不起作用。对于适用于无限和有限流的所有可能组合的解决方案，在hasNext 方法中检查两个源的中间Iterator 似乎是不可避免的¹：

static <A, B> Stream<Pair<A,B>> zip(Stream<A> as, Stream<B> bs) {
    Iterator<A> i1 = as.iterator();
    Iterator<B> i2 = bs.iterator();
    Iterable<Pair<A,B>> i=()->new Iterator<Pair<A,B>>() {
        public boolean hasNext() {
            return i1.hasNext() && i2.hasNext();
        }
        public Pair<A,B> next() {
            return new Pair<A,B>(i1.next(), i2.next());
        }
    };
    return StreamSupport.stream(i.spliterator(), false);
}

如果您想要并行压缩，您应该考虑Stream 的来源。例如。你可以压缩两个ArrayLists（或任何RandomAccessList）喜欢

ArrayList<Foo> l1=new ArrayList<>();
ArrayList<Bar> l2=new ArrayList<>();
IntStream.range(0, Math.min(l1.size(), l2.size()))
         .mapToObj(i->new Pair(l1.get(i), l2.get(i)))
         . …

¹（除非您直接实现 Spliterator）

【讨论】：

刚刚发现，此解决方案不适用于无限的 B 流。在这种情况下，它是一个无限循环。 B-Stream 必须以某种方式受到限制。但是，我没有找到对您的上述代码进行微小更改的解决方案。链接的答案似乎也适用于无限流：link
@F. Böller：是的，解决这个问题不小。您链接的解决方案可能有效，但我建议您注意许可问题，因为代码是从 beta jdk 源代码中复制出来的，正如回答者自己所说的那样。您还应该记住，可能还有其他问题，因为代码的作者可能有理由将其从 jdk 中删除......