Frage zu atomaren Operationen ohne Locks

[Novanic]

Hallo Leute,

ich habe ein Operation die noch nicht atomar ist und möchte dabei gerne auf Locks verzichten. Es geht um eine Map die Collections als Value hält. Wenn eine Collection leer ist, soll die Methode den entsprechenden Eintrag aus der Map entfernen. Das Problem dabei ist, dass zwischen der Prüfung von isEmpty() und dem Aufruf von remove() ein anderer Thread etwas zu der Collection adden könnte. Dadurch würden die gerade hinzugefügten Elemente einfach verloren gehen...

    private void removeOnEmpty(Map<String, Collection> aMap, String aKey) {
        Collection theObjects = aMap.get(aKey);
        
        //NICHT ATOMAR
        if(theObjects.isEmpty()) {
            aMap.remove(aKey);
        }
        //NICHT ATOMAR ENDE
    }

Ist es möglich, dass ohne Locks (syncronized), mit Atomics zu lösen? Wahrscheinlich ist das nicht möglich, weil es sich um zwei verschiedene Collections handelt oder?

Danke schonmal.

Gruß Nova

 

[HoaX]

Selbst ein synchronized um diesen Abschnitt würde dir nichts bringen. Du bräuchtest auch eine eigene Collection-Klasse die du vor Veränderungen sperren kannst.

 

[KSG9|sebastian]

Yep, synchronized bring dir hier auch nix. Du müsstest mit entsprechenden Locks arbeiten, z.B: aus dem java.util.concurrent-Package

 

[Novanic]

Ah, ich glaube ich hab doch noch eine schönere Lösung gefunden. Eine ConcurrentMap bietet die Methode remove(key, value) an. Wenn ich als Value meine leere Collection reingebe und in Wirklichkeit hat sich die Collection schon wieder verändert, sollte bei remove() nichts passieren. Wichtig dabei ist aber wohl, dass ich eine neue, leere Collection reingebe, weil ich ja sonst mit der Referenz arbeiten würde...

Das Problem ist damit gelöst (getestet mit Multi-Threading-Test).

Die Methode sieht jetzt also so aus:

    private void removeOnEmpty(ConcurrentMap<String, Collection> aMap, String aKey) {
        Collection theObjects = aMap.get(aKey);
        
        //atomare Operation (isEmpty() ist eigentlich unnötig, dürfte in den meisten Fällen aber für mehr Performance sorgen)
        if(theObjects.isEmpty()) {
            aMap.remove(aKey, new ConcurrentSkipListSet());
        }
    }

Gruß Nova