atomic

作者: coder_liu | 来源:发表于2017-07-29 15:26 被阅读0次

    Unsafe

    allocateInstance能直接初始化一个private的构造或特殊构造方法的实例。它的构造方法是private,所以通过getUnsafe静态方法调用

    简单说明一下CAS

    cas就是比较交换原则。基本上涉及的比较是volatile变量修饰的属性,获取之后当做和比较的基本,如果期间没有修改则,比较是成功的,说明恶意更新值。否则,死循环再次获取volatile修饰属性值,反复对比直至没有改变,可替换为新值,替、换完后跳出死循环。

    AtomicInteger

    使用compareAndSet短操作,死循环的方式添加\设置\减值。
    valueOffset是值得地址,comparseAndSet是从依据当前期待的值是否和内存中的地址值是否一致,如果一致,则说明update的值能是最新的,直接变更。但是对应的offset会变更吗?答案是不会,给定的字段偏移量是固定不变的。

    AtomicBoolean

    这里记录的值不是boolean,而是int的value,其他的和atomicInteger类似。

    AtomicIntegerArray

    unsafe.arrayBaseOffset(int[].class)获取数组第一个元素的偏移量;
    unsafe.arrayIndexScale(int[].class)获取数组元素的增量地址;
    shift=31-Integer.numberOfLeadingZeros(scale)增量的非0位,增量位移位;
    unsafe.getIntVolatile(array, offset)获取数组中偏移位为offset对应的值;
    checkedByteOffset->byteOffset 这个是第i个元素的偏移位的值;

    AtomicIntegerFieldUpdater<T>

    AtomicIntegerFieldUpdater是修改针对对象中的field的offset,地址处修改value值;
    它的inner private static 实现类AtomicIntegerFieldUpdaterImpl<T>,其中需要检查方法的权限、包访问权限。使用unsafe.putIntVolatile(obj, offset, newValue);

    AtomicLong

    和AtomicInteger类似,多了一个VM_SUPPORTS_LONG_CAS但是感觉像是判断JVM是否支持Long类型的CAS

    AtomicLongArray

    和AtomicIntegerArray类似

    AtomicLongFieldUpdater<T>

    大致和AtomicIntegerFieldUpdater类似,但是还是会区分是否支持Long类型的CAS。
    如果支持Long CAS,则使用内部类CASUpdater,否则使用LockedUpdater(synchronized关键字控制)

    AtomicMarkableReference<T>

    由内部类Pair<T>属性Reference<T>、mark(boolean类型)组成,其中比较逻辑相对来说很关键如下:

    //是比较新的和旧的对象引用及mark标识。如果一样直接不用cas交换。
     public boolean compareAndSet(V expectedReference, V newReference,boolean    expectedMark, boolean newMark) {
            Pair<V> current = pair;
            return
                expectedReference == current.reference &&
                expectedMark == current.mark &&
                ((newReference == current.reference &&
                  newMark == current.mark) ||
                 casPair(current, Pair.of(newReference, newMark)));
        }
          private boolean casPair(Pair<V> cmp, Pair<V> val) {
            return UNSAFE.compareAndSwapObject(this, pairOffset, cmp, val);
        }
    

    AtomicReference<T>

    对象的动态关联 T,使用的也是UNSAFE.compareAndSwapObject(this, pairOffset, cmp, val);

    AtomicReferenceArray<T>

    这个就是atomicReference和AtomicXXXArray的结合体。真正关联的是实体数组。

    AtomicReferenceFieldUpdater<T>

    AtomicReferenceFieldUpdater(Class objectClazz, Class fieldClazz, String fieldName) 指定好T Class、字段Class和字段名,AtomicReferenceFieldUpdaterImpl是内部私有的静态不可继承的实现类(private static final class),但是没弄明白Reflection这个获取的callerClass能不能有作用。

    AtomicStampedReference

    内部静态类private static class Pair<T>包含T对象和stamp的int。感觉和AtomicMarkableReference<T>整体来说差不多。只不过,这个Pair中式stamp(int)而他是mark(boolean)

    相关文章

      网友评论

          本文标题:atomic

          本文链接:https://www.haomeiwen.com/subject/pgcclxtx.html