Holen und entfernen Sie alle aktuellen Einträge von einer ConcurrentMap

Question

Ich habe eine ConcurrentHashMap akkumuliert einige Änderungen, die in regelmäßigen Abständen irgendwo gesendet werden sollten (für eine Art der Replikation). Bei den Änderungen ist nur der letzte Wert für einen Schlüssel von Bedeutung.

Also muss ich einige Schnappschüsse bekommen und entfernen. Der Snapshot muss nicht atomar sein, es reicht aus, wenn jeder seiner Einträge den Status der ursprünglichen Map während des Vorgangs in einem bestimmten Moment wiedergibt.

Der wichtige Teil ist, dass nur die Einträge, die im Ergebnis vorhanden und aktuell sind, aus der ursprünglichen Karte entfernt werden können. Ich schätze, folgendes sollte tun:

<K, V> ConcurrentMap<K, V> getAndRemoveAll(ConcurrentMap<K, V> map) { 
    ConcurrentHashMap<K, V> result = new ConcurrentHashMap<>(map);  
    result.forEach((resultKey, resultValue) -> 
    map.computeIfPresent(resultKey, 
     (k, mapValue) -> mapValue==resultValue ? null : mapValue)); 
    return result; 
} 

Ist das wirklich richtig? Ist es in einer einzigen Iteration möglich?

Answer 1

Sie können die Methode remove(Object key, Object value) verwenden, die nur den Eintrag entfernt, wenn der Wert aktuell ist, und der Vorgang ist atomar.

So ist es das, was ich vorschlagen:

<K, V> Map<K, V> getAndRemoveAll(ConcurrentMap<K, V> map) { 
    return map.entrySet().stream() 
    .filter(e -> map.remove(e.getKey(), e.getValue())) 
    .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); 
}