Java中的Map【四】ConcurrentMap接口

53 阅读 0 评论 35 点赞

我是靠谱客的博主机智玫瑰，最近开发中收集的这篇文章主要介绍Java中的Map【四】ConcurrentMap接口，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

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

2.1.4 ConcurrentMap接口

ConcurrentMap<K,V>接口继承Map<K,V>接口，是一种提供线程安全性和原子性保证的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<K,V>接口中均有定义，并且都是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都根据内部结构重写了以上方法，后续再具体实现分析。