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