java - ChronicleMap 和 parallelStream

Question

我正在尝试使用 chronicleMap.parallelStream:

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

我得到以下异常。

java.lang.IllegalStateException: ChronicleMap ... Iterator should be accessed only from a single thread

知道如何使用 chronicleMap 和 parallelStream 吗？谢谢

Answer 1

如果 chronicle 不支持并行流，那么您必须将其内容复制到支持的 map 实现中。

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