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);