由並行流填充的ArrayList包含空值

Question

我創建一個列表並使用並行流從其他列表中填充它，意外的是目標列表包含空值。它很少發生，不穩定。有人有同樣的問題嗎？

下面是一段代碼：

Collection<DestinationObj> DestinationObjList = Lists.newArrayList(); 
SourceObjList.parallelStream().forEach(portalRule -> DestinationObjList.add(new DestinationObj(portalRule))); 
return DestinationObjList; 

Answer 1

有在java.util.concurrent併發列表實現。特別是CopyOnWriteArrayList。

- 賈羅德羅伯遜

看吧：Is there a concurrent List in Java's JDK?

Answer 2

你應該收集並聯有點不同的方式：

SourceObjList.parallelStream() 
     .map(DestinationObj::new) 
     .collect(Collectors.toCollection(ArrayList::new)); 

您有問題是ArrayList不線程安全的，因此結果真的沒有定義。 注意，使用並行流不需要線程安全集合 - Lists::newArrayList不需要。

Answer 3

使用收集器同步對目標列表的訪問會給您在同步中的性能損失。實際上，您可以在沒有同步的情況下執行相同的操作，因爲您知道源列表的大小，因此可以從一開始就創建所需大小的目標列表。

DestinationObj[] dest = new DestinationObj[sourceObjList.size()]; 
IntStream.range(0, sourceObjList.size()) 
    .parallel() 
    .forEach(i -> dest[i] = new DestinationObj(sourceObjList.get(i))); 
List<DestinationObj> destinationObjList = Arrays.asList(dest); 

編輯：只是把霍爾格的改進這裏爲清楚：

List<DestinationObj> destinationObjList = Arrays.asList(
     sourceObjList 
      .parallelStream() 
      .map(DestinationObj::new) 
      .toArray(DestinationObj[]::new));