多线程并发 (四) Atomic类型

CSDN个人博客:https://blog.csdn.net/wangrain1

了解了Java虚拟机,线程,锁,volatile概念之后对多线程开发算是比较熟悉了。解决线程并发产生的问题,除了锁,volatile等关键字之外,在特定的情景下为了提高代码运行的效率,为了摆脱“锁”这个独占式的编程方式之外,还有另外一个原子类的概念。

在java.util.concurrent.atomic包下有Java提供的线程安全的原子类。了解 AtomicInteger 和 CAS 机制。

1. AtomicInteger的实现

通过上一篇中volatile的自增的例子,我们知道要想实现这种自赠的效果就需要加锁,为了提高效率,这种场景下原子类型就可以胜任。

AtomicIntegerai =new AtomicInteger(1);

ai.incrementAndGet();

查看实现代码:

/**

    * Atomically increments by one the current value.

    *

    * @return the updated value

    */

    public final int incrementAndGet() {

        return U.getAndAddInt(this, VALUE, 1) + 1;

    }

根据incrementAndGet()方法了解到AtomicInteger是对U的一个封装,U就是Unsafe类。

    private static final sun.misc.Unsafe U = sun.misc.Unsafe.getUnsafe();

    private static final long VALUE;

    static {

        try {

            VALUE = U.objectFieldOffset

                (AtomicInteger.class.getDeclaredField("value"));

        } catch (ReflectiveOperationException e) {

            throw new Error(e);

        }

    }

    private volatile int value;

这段代码首先获得Unsafe对象,先声明一下Unsafe是个单例,Unsafe里面基本都是native方法。

static代码块里面初始化了VALUE这个值,static修饰的类加载的时候就会被初始化,并且引用是放到 Jvm的方法区的属于类的数据。

继续VALUE是什么呢?查看U.objectFieldOffset()方法:

/**

    * Gets the raw byte offset from the start of an object's memory to

    * the memory used to store the indicated instance field.

    *

    * @param field non-null; the field in question, which must be an

    * instance field

    * @return the offset to the field

    */

    public long objectFieldOffset(Field field) {

        return field.getOffset();

    }

看方法注释:从对象的内存处开始,获得原始字节偏移量,用于存储实力对象的内存。好像还是不理解~。画个图:

上几篇提到对象在内存中的分布其中有个padding对齐,就是保证一个对象的内存大小必须是8的倍数。在这里偏移量的意思就像我们 new 一个数组,数组的地址就是数组地一个元素的地址,假如数组地址是 a,第二个元素就是a+1,其中+1就是偏移量。对应的对象的一个属性的偏移量就是其对象的地址开始增加,增加的数就是这个filed的偏移量。

对于VALUE这个值我们知道了,他是AtomicInteger中的value属性对应的偏移量,就是对象地址+VALUE = value的地址

继续看代码:

/**

    * Atomically increments by one the current value.

    *

    * @return the updated value

    */

    public final int incrementAndGet() {

        return U.getAndAddInt(this, VALUE, 1) + 1;

    }

/**

    * Atomically adds the given value to the current value of a field

    * or array element within the given object {@code o}

    * at the given {@code offset}.

    *

    * @param o object/array to update the field/element in

    * @param offset field/element offset

    * @param delta the value to add

    * @return the previous value

    * @since 1.8

    */

    // @HotSpotIntrinsicCandidate

    public final int getAndAddInt(Object o, long offset, int delta) {

        int v;

        do {

            v = getIntVolatile(o, offset);

        } while (!compareAndSwapInt(o, offset, v, v + delta));

        return v;

    }

知道了offset值的意义之后

继续向下就是 v = getIntVolatile(o, offset); 这段代码,这个代码含义其实就是根据object和属性在object中的偏移地址,拿到 v(对应的共享内存中的 value 值,通过volatile控制值的可见性)。

compareAndSwapInt(o, offset, v, v + delta) 这个就是CAS(CompareAndSwap)机制 = 先拿着 v(预期的值)和 共享内存的值做比较 如果其他线程没有修改过就替换掉,否则就一直自旋判断直到成功。

如果在比较过程中不成功,也就是值被其他线程修改了,这时候CAS机制是一直循环的,这样无非也会消耗大量CPU。

2. CAS实现原子性操作的三大问题

这部分引用于:https://www.jianshu.com/p/5ee20d1128da

CAS虽然很高的解决了原子操作,但是CAS仍然存在三大问题。ABA问题、循环时间长开销大、以及只能保证一个共享变量的原子操作。

ABA问题

因为CAS需要在操作值的时候,检查值有没有发生变化,如果发生变化则更新,但是如果一个值为A,变成了B,又变成了A,那么使用CAS进行检查时就会发现它的值没有发生变化,但实际上发生变化了。ABA问题的解决思路就是使用版本号,在变量前边追加版本号,每次变量更新的时候把版本号加1,那么A→B→A就会变成1A→2B→3A。举个通俗点的例子,你倒了一杯水放桌子上,干了点别的事,然后同事把你水喝了又给你重新倒了一杯水,你回来看水还在,拿起来就喝,如果你不管水中间被人喝过,只关心水还在,这就是ABA问题。

从java1.5开始,JDK提供了AtomicStampedReference、AtomicMarkableReference来解决ABA的问题,通过compareAndSet方法检查值是否发生变化以外检查版本号知否发生变化。

循环时间长开销大

自旋CAS如果长时间不成功,会给CPU带来非常大的执行开销。

只能保证一个共享变量的原子操作

当对一个共享变量执行操作时,我们可以使用循环CAS的方式来保证原子操作,但是对多个共享变量操作时,循环CAS就无法保证操作的原子性,这个时候就可以用锁。

从Java 1.5开始,JDK提供了AtomicReference类来保证引用对象之间的原子性,就可以把多个变量放在一个对象里来进行CAS操作。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 223,343评论 6 521
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 95,508评论 3 400
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 170,182评论 0 366
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 60,374评论 1 300
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 69,372评论 6 398
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 52,926评论 1 314
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 41,333评论 3 426
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 40,285评论 0 277
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,813评论 1 321
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,887评论 3 343
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 41,016评论 1 354
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 36,677评论 5 351
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 42,350评论 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,843评论 0 25
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,960评论 1 275
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 49,493评论 3 379
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 46,038评论 2 361

推荐阅读更多精彩内容