流：CONCAT

Question

後指定者崩潰我有一些代碼看起來像這樣：

Stream a = Streams.from(...).map(...); 
Stream b = Streams.from(...); 
Stream c = Stream.concat(a, b); 
c.toArray(); 

（Streams.from(Iterable)創建從一個可迭代流 - 被視爲Iterable#stream()不存在）

最後一行崩潰但有：

Exception in thread "main" java.lang.IllegalStateException: Accept exceeded fixed size of 266 
    at java.util.stream.Nodes$FixedNodeBuilder.accept(Nodes.java:1224) 
    at java.util.Iterator.forEachRemaining(Iterator.java:116) 
    at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801) 
    at java.util.stream.Streams$ConcatSpliterator.forEachRemaining(Streams.java:743) 
    at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:512) 
    at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:502) 
    at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:576) 
    at java.util.stream.AbstractPipeline.evaluateToArrayNode(AbstractPipeline.java:255) 
    at java.util.stream.ReferencePipeline.toArray(ReferencePipeline.java:438) 
    at ... (my code) 

266實際上是流的大小a。流b是11個元素。

我做了一些測試。從代碼中刪除map(...)使其工作。 下面的小例子也可以工作：

Stream x = Stream.of(1, 2).map(w -> w + 1); 
Stream y = Stream.of(3, 4); 
Stream z = Stream.concat(x, y); 
z.toArray(); 

在這一點上我是非常懷疑我的映射功能，然而，這只是正常工作：

Object[] a = Streams.from(...).map(...).toArray(); 
Object[] b = Streams.from(...).toArray(); 
Object[] c = ArrayUtils.addAll(a, b); 

是否有可能解釋這種怪異的流API微妙行爲？

提到流b是從調用映射函數時被填充的集合構建而成。

Answer 1

看來，因爲它使用的Collection.spliterator()默認實現其假定Collection不在流操作過程中修改（特別是其size()不會改變）源收集流b被錯誤地執行。在你的情況下，這似乎是錯誤的。

沒有看到您的收藏的完整代碼，建議修復並不是那麼容易。如果可能的話，您可以在調用size()方法時執行初始化，因此在遍歷集合之前調用size()將返回正確的大小（目前它似乎返回0）。另一種方法是重寫spliterator()方法是這樣的：

public Spliterator<E> spliterator() { 
    return Spliterators.spliteratorUnknownSize(this.iterator(), Spliterator.ORDERED); 
} 

這樣的SIZED特點不報告和數據流管道將不依賴於規模。現在toArray()可能會工作得更慢，因爲數組重新分配可能變得必要，但它會正常工作。