首页  

ConcurrentHashMap在jdk7和8中的区别     所属分类 java 浏览量 1372
jdk7

锁分离技术


static final class Segment< K,V> extends ReentrantLock implements Serializable

// The segments, each of which is a specialized hash table.
final Segment< K,V>[] segments;

Segment 是个特殊的 hashmap 
private void rehash(HashEntry< K,V> node)

在Segment上扩容


ReentrantLock+Segment+HashEntry

代码行数 1620

public ConcurrentHashMap(int initialCapacity,float loadFactor, int concurrencyLevel)
根据 concurrencyLevel 计算 Segment 数量

        int ssize = 1;
        while (ssize < concurrencyLevel) {
            ++sshift;
            ssize <<= 1;
        }
        

static final int DEFAULT_INITIAL_CAPACITY = 16;
static final float DEFAULT_LOAD_FACTOR = 0.75f;
static final int DEFAULT_CONCURRENCY_LEVEL = 16;
    

    


jdk8 Node数组+链表+红黑树 synchronized+CAS+HashEntry+红黑树 注意使用的是 synchronized ,不是 ReentrantLock 数据结构类似HashMap 链表的数量大于8,转换成黑红树 代码行数 6312
1 整体结构 1.7 Segment + HashEntry + Unsafe 1.8 移除Segment,锁的粒度更小,Synchronized + CAS + Node + Unsafe 2 put 1.7 先定位Segment,再定位桶,put全程加锁,没有获取锁的线程提前找桶的位置,并最多自旋64次获取锁,超过则挂起。 1.8 移除Segment,类似HashMap,可以直接定位到桶,拿到first节点后进行判断,1、为空则CAS插入;2、为-1则说明在扩容,则跟着一起扩容;3、else则加锁put(类似1.7) 3 get 基本类似,value声明为volatile,保证了修改的可见性,不需要加锁。 4 resize 1.7 跟HashMap步骤一样,只不过是搬到单线程中执行,避免了HashMap在1.7中扩容时死循环的问题,保证线程安全。 1.8 支持并发扩容,HashMap扩容在1.8中由头插改为尾插(避免死循环问题),ConcurrentHashmap也是,迁移从尾部开始,扩容前在桶的头部放置一个hash值为-1的节点,这样别的线程访问时就能判断是否该桶已经被其他线程处理过了。 5 size 1.7 计算两次,如果不变则返回计算结果,若不一致,则锁住所有的Segment求和 1.8 参考 LongAdder final long sumCount() { CounterCell[] as = counterCells; CounterCell a; long sum = baseCount; if (as != null) { for (int i = 0; i < as.length; ++i) { if ((a = as[i]) != null) sum += a.value; } } return sum; }

上一篇     下一篇
docker Busybox 实战

java调用c方法JNA实例

java堆外内存回收机制

优秀投资者的十大特征

springboot web端口设置三种方式

springboot2 actuator 使用