Скользящая карта с наименьшим значением

Question

Мне нужна реализация карты , которая поддерживает параллелизм и сохраняет только наименьшую/большую добавленную стоимость (в зависимости от компаратора). Будет ли работать следующий код?

class LeastValConcurrentMap<K, V> { 

    //put the least value 
    private final Comparator<V> comparator; 
    private final ConcurrentHashMap<K, V> map = new ConcurrentHashMap<K, V>(); 

    LeastValConcurrentMap(Comparator comparator) { 
    this.comparator = comparator; 
    } 

    public void put(K k, V v) { 
    V vOld = map.put(k, v); 
    if (vOld == null || comparator.compare(v, vOld) <= 0) //i.e. v <= vOld so better 
     return; 
    //recursively call self 
    put(k, vOld); 
    } 

    @Override 
    public String toString() { 
    return map.toString(); 
    } 
} 

Не могли бы вы привести пример того, где/почему это не сработает? Есть ли что-то в guava или стандартной java-библиотеке, которую я мог бы использовать?

Answer 1

Возможно, вам потребуется синхронизировать метод put класса LeastValConcurrentMap. Кажется, вы только кладете ценности на карту .. где/как эти значения будут использоваться. Чтобы обеспечить параллельный доступ, вам нужно подумать об операциях чтения и записи. Кроме того, последняя строка вашего метода пут должна быть как map.put (к, VOLD)

Answer 2

Я думаю, что это более сложное, вам нужно использовать атомным ConcurrentHashMap.replace(K key, V oldValue, V newValue)

public void put(K k, V v) { 
    V oldValue = map.putIfAbsent(k, v); 
    if (oldValue == null) { 
     // this is the first mapping to this key 
     return; 
    } 
    for (;;) { 
     if (comparator.compare(v, oldValue) <= 0) { 
      break; 
     } 
     // this replace returns true only if oldValue was replaced with new value atomically 
     if (map.replace(k, oldValue, v)) { 
      break; 
     } 
     // otherwise another attempt 
     oldValue = map.get(k); 
    }