2014-09-25 27 views
0

如果我從自己的Iterable創建並行流這樣的: 迭代器同步並行流

StreamSupport.stream(new FilesToProcessIterable(customerId).spliterator(), true) 

我必須關心的狀態同步迭代器裏面執行,否則將通過流或Spliterator本身採取?

回答

0

寫在javadoc

強烈建議spliterator報告不可改變或同時

特徵因此,無論你做一個迭代器,它是線程安全的,或者你實現一個但該方法不會使其線程安全。您可以使用供應商版本作爲替代方案。

+0

我意識到我選擇了錯誤的方式去了:)我面對經典的生產者 - 消費者問題,但沒有意識到這一點,並開始發明一些複雜的東西。但是你的回答在任何方面似乎都是正確的。 – 2014-09-25 13:39:41