Java中的Map【四】ConcurrentMap接口-蒲公英云

Java中的Map【四】ConcurrentMap接口

港控/mmm° 2021-09-20 23:20 841阅读 0赞

所使用的jdk版本为1.8版本，先看一下ConcurrentMap在JDK中Map的UML类图中的位置：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIyMDc2MzQ1_size_16_color_FFFFFF_t_70

2.1.4 ConcurrentMap接口

ConcurrentMap接口继承Map接口，是一种提供线程安全性和原子性保证的Map。分析一下里面的方法：

1、非default方法：

V putIfAbsent(K key, V value);
boolean remove(Object key, Object value);
boolean replace(K key, V oldValue, V newValue);
V replace(K key, V value);

这四个方法在Map接口中均有定义，并且都是default方法。在ConcurrentMap中因为这些方法需要保证多线程下的原子性，因此需要实现类具体实现，在ConcurrentMap中都是abstract方法。

2、重写Map中的default方法

（1）default V getOrDefault(Object key, V defaultValue)

default V getOrDefault(Object key, V defaultValue) {
        V v;
        return ((v = get(key)) != null) ? v : defaultValue;
    }
  与Map中的方法不同的是，没有进行containsKey(key)这一步的判断。此实现假定ConcurrentMap不能包含null作为value值，而get(key)返回null明确表示key不存在。所以如果支持null作为value值的实现类，必须重写此默认实现。

（2）default void forEach(BiConsumer<? super K, ? super V> action)

@Override
    default void forEach(BiConsumer<? super K, ? super V> action) {
        Objects.requireNonNull(action);
        for (Map.Entry<K, V> entry : entrySet()) {
            K k;
            V v;
            try {
                k = entry.getKey();
                v = entry.getValue();
            } catch(IllegalStateException ise) {
                // this usually means the entry is no longer in the map.
                continue;
            }
            action.accept(k, v);
        }
    }

与Map中的方法实现一致。传入函数式接口，用于遍历Map。

（3）default V merge(K key, V value, BiFunction<? super V, ? super V, ? extends V> remappingFunction)、

     default V compute(K key, BiFunction<? super K, ? super V, ? extends V> remappingFunction)等方法默认实现与Map中有所不同，当多个线程尝试更新（包括可能多次调用方法）时，默认实现可能会重试这些步骤，里面有一个for(;;)结构体（比较简单，注释清楚）。具体的实现类如ConcurrentHashMap都根据内部结构重写了以上方法，后续再具体实现分析。