ChronicleMap和parallelStream

Question

我'嘗試使用chronicleMap.parallelStream：

myChronicleMap.entrySet().parallelStream().forEach((entry) -> { 
    process(entry); //heavy process 
} 

我得到了以下異常。

java.lang.IllegalStateException：ChronicleMap ...迭代器應該只從單個線程

不知道如何使用chronicleMap和parallelStream訪問？ 謝謝

Answer 1

如果編年史不支持並行流，那麼你將不得不將其內容複製到一個映射實現中。

Map<?, ?> mapCopy = myChronicleMap.entrySet() 
            .stream() 
            .collect(Collectors.toMap(Entry::getKey, Entry::getValue)); 
mapCopy.entrySet().parallelStream().forEach(this::process);