ChronicleMapとparallelStream

Question

I'am：

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