zoukankan      html  css  js  c++  java
  • LongAdder & AtomicInteger

    JDK8 推荐  LongAdder替代 AtomicInteger, 

    AtomicInteger内部是实现使用 (网友使用jad反编译源码 参考 http://ifeve.com/enhanced-cas-in-jdk8/),高并发场景compareAndSwapInt 会不断的试错,有性能问题。

    public final int getAndAddInt(Object obj, long l, int i) {
        int j;
        do
            j = getIntVolatile(obj, l);
        while(!compareAndSwapInt(obj, l, j, j + i));
        return j;
    }
    
    public native int getIntVolatile(Object obj, long l);
    public final native boolean compareAndSwapInt(Object obj, long l, int i, int j);

    LongAdder在AtomicLong的基础上将单点的更新压力分散到各个节点,在低并发的时候通过对base的直接更新可以很好的保障和AtomicLong的性能基本保持一致,而在高并发的时候通过分散提高了性能。 

    将待处理的数据,通过hash计算分散到Cell数组中分别处理,最后在汇总计算。

    注意casBase   ==>   !casBase(b = base, b + x);表示CAS更新操作;如果一个线程去CAS失败,那么表示正在有一个线程正在CAS操作,表示竞争激烈;

       // LongAdder 
       public void add(long x) {
            Cell[] as; long b, v; int m; Cell a;
            //  !casBase(b = base, b + x);表示CAS更新操作;如果一个线程去CAS失败,那么表示正在有一个线程正在CAS操作,表示竞争激烈;
            if ((as = cells) != null || !casBase(b = base, b + x)) {
                boolean uncontended = true;
                if (as == null || (m = as.length - 1) < 0 ||
                    (a = as[getProbe() & m]) == null ||
                    !(uncontended = a.cas(v = a.value, v + x)))
                    longAccumulate(x, null, uncontended);
            }
        }

    LongAddr在高并发的时候,Cell数组的汇总计算会不准确, 在高并发获取全局唯一ID的时候,使用AtomicLong而不是LongAddr

    参考  

    https://www.jianshu.com/p/67a75e36166f

    https://www.cnblogs.com/gosaint/p/9129867.html

  • 相关阅读:
    【001】JS解析,反解析XML的一些问题
    [ Java面试题 ]并发篇
    [ Java面试题 ]WEB篇
    [ Java面试题 ]算法篇
    [ Java面试题 ]数据库篇
    [ Java面试题 ]泛型篇
    [ Java面试题 ]多线程篇
    [ Java面试题 ]持久层篇
    Java开发岗面试知识点解析
    [ SSH框架 ] Spring框架学习之二(Bean的管理和AOP思想)
  • 原文地址:https://www.cnblogs.com/webglcn/p/10638708.html
Copyright © 2011-2022 走看看