AtomicInteger类源码笔记

AtomicInteger类位于concurrent.atomic包下,它的主要用来支持对int或Integer类型进行的原子操作。原子操作可以保证线程安全性,因此,AtomicInteger类也常常用来做线程安全计数器,他的作用是int和Integer不可替代的。

原子操作指一个操作不可被分割,也不可被重排序,执行的结果要么成功要么失败。这里的操作可以是一条或多条指令。

AtomicInteger类也继承了Number类。Number类是一个抽象类,也是所有可以转换成基础类型的数值型类的父类。他的主要作用是对数值型数据类型转换进行规范。

public class AtomicInteger extends Number implements java.io.Serializable

所在路径:\java\util\concurrent\atomic\AtomicInteger.java

AtomicInteger类成员变量
AtomicInteger类方法列表

一、成员变量

首先是常规成员变量,包括序列化id和value等。需要注意的是,这里的value属性是被volatile关键字修饰的,这是多线程临界资源定义的一种常规手法,表明该属性具有对多个线程的可见性并被禁止指令重排序。

/** serialVersionUID */
private static final long serialVersionUID = 6214790243416807050L;
/** 存储对象值 */
private volatile int value;
/** 存储对象在内存中的偏移量 */
private static final long valueOffset;

在当前的 Java 内存模型下,线程可以把变量保存到本地内存(比如机器的寄存器)中,而不是直接在主存中进行读写。这就可能造成一个线程在主存中修改了一个变量的值,而另外一个线程还继续使用它在寄存器中的变量值的拷贝,造成数据的不一致。

要解决这个问题,就需要把变量声明为volatile,这就指示 JVM,这个变量是不稳定的,每次使用它都到主存中进行读取。

除了常规成员变量,AtomicInteger类还定义了一个Unsafe类型变量以对直接内存进行操作。Unsafe类位于sun.misc包下,用来操作直接内存,它提供的方法多数是native的。

// setup to use Unsafe.compareAndSwapInt for updates
private static final Unsafe unsafe = Unsafe.getUnsafe();

此外,AtomicInteger类定义了一个静态代码块,用来获取value属性在内存中的偏移量。

static {
    try {
        valueOffset = unsafe.objectFieldOffset
            (AtomicInteger.class.getDeclaredField("value"));
    } catch (Exception ex) { throw new Error(ex); }
}

静态代码块随着类的加载而执行,且只执行一次,它的原理和static关键字是类似的。一个类中代码块的执行顺序为:静态代码块 -> 构造代码块 -> 构造函数

https://www.cnblogs.com/ysocean/p/8194428.html

二、构造器

AtomicInteger的构造器比较简单,直接使用默认构造器获得一个为0或value初始值,或者通过参数给它赋值。

public AtomicInteger() {
}

public AtomicInteger(int initialValue) {
    value = initialValue;
}

三、set()和lazySet()

想要在初始化完成后对value进行赋值,就需要使用set()方法。AtomicInteger提供了两种set方式。

1、set()

set()方法可以完成一次直接赋值。

public final void set(int newValue) {
    value = newValue;
}
2、lazySet()

lazySet()方法实现了对value的非volatile赋值,通过调用unsafe.putOrderedInt()方法,直接向固定偏移量的内存上写入数据,但不使其对其他线程立刻可见(putOrderedInt()是putIntVolatile()的延迟实现)。

public final void lazySet(int newValue) {
    unsafe.putOrderedInt(this, valueOffset, newValue);
}

lazySet()方法存在的意义是在某些不需要volatile的场景下,通过延迟赋值提高程序运行的效率。这个方法很少被上层调用者使用。

lazySet()方法:https://blog.csdn.net/bluetjs/article/details/52423867

四、get()

想要获取value的值就需要使用get()方法,AtomicInteger除了提供基本的get()方法之外,还提供了getAndSet(),getAndIncrement(),getAndDecrement(),getAndAdd(),getAndUpdate()和getAndAccumulate()等方法。

1、get()
public final int get() {
    return value;
}
2、getAndSet()

getAndSet()方法实际上调用getAndSetInt()方法,它的底层实现逻辑是利用getIntVolatile()方法获取value后进行的自旋CAS操作。

public final int getAndSet(int newValue) {
    return unsafe.getAndSetInt(this, valueOffset, newValue);
}

其中unsafe.getAndSetInt()方法的源码如下所示,这两个方法都是native方法。

public final int getAndSetInt(Object var1, long var2, int var4) {
    int var5;
    do {
        var5 = this.getIntVolatile(var1, var2);
    } while(!this.compareAndSwapInt(var1, var2, var5, var4));

    return var5;
}

CAS操作:https://www.jianshu.com/p/ab2c8fce878b

3、getAndIncrement(),getAndDecrement()和getAndAdd()

这两个方法实现的原理和getAndSet()方法基本是一样的,只是将get出来的value加1或减1了而已。

/** 自增就是加1,返回自增前的值 */
public final int getAndIncrement() {
    return unsafe.getAndAddInt(this, valueOffset, 1);
}

/** 自减就是减1,返回自增前的值 */
public final int getAndDecrement() {
    return unsafe.getAndAddInt(this, valueOffset, -1);
}

/** Add操作就是可以自定义增加的值 */
public final int getAndAdd(int delta) {
    return unsafe.getAndAddInt(this, valueOffset, delta);
}

public final int getAndAddInt(Object var1, long var2, int var4) {
    int var5;
    do {
        var5 = this.getIntVolatile(var1, var2);
    } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));

    return var5;
}

/** 自增的同时返回自增后的值 */
public final int incrementAndGet() {
    return unsafe.getAndAddInt(this, valueOffset, 1) + 1;
}

/** 自减的同时返回自减后的值 */
public final int decrementAndGet() {
    return unsafe.getAndAddInt(this, valueOffset, -1) - 1;
}
4、getAndUpdate()和getAndAccumulate()

getAndUpdate()和getAndAccumulate()分别以函数式编程接口IntUnaryOperator和IntBinaryOperator为入参,实现AtomicInteger的自定义变换。用户可以自定义一个函数,让value按函数计算结果递增,也可以定义两个可以互相翻转的int,使value交替变换。

public final int getAndUpdate(IntUnaryOperator updateFunction) {
    int prev, next;
    do {
        prev = get();
        next = updateFunction.applyAsInt(prev);
    } while (!compareAndSet(prev, next));
    return prev;
}

public final int getAndAccumulate(int x,
                                  IntBinaryOperator accumulatorFunction) {
    int prev, next;
    do {
        prev = get();
        next = accumulatorFunction.applyAsInt(prev, x);
    } while (!compareAndSet(prev, next));
    return prev;
}

可以看到,两个方法的核心都是compareAndSet(),它的源码为:

/**
 * Atomically sets the value to the given updated value
 * if the current value {@code ==} the expected value.
 *
 * @param expect the expected value
 * @param update the new value
 * @return {@code true} if successful. False return indicates that
 * the actual value was not equal to the expected value.
 */
public final boolean compareAndSet(int expect, int update) {
    return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}

与之相对的是weakCompareAndSet()方法,它是一个少数情况下compareAndSet()方法的替代。JDK8及以前,这两个方法的实现代码完全一样,而在JDK9之后,weakCompareAndSet()方法增加了@HotSpotIntrinsicCandidate注解。

/**
 * Atomically sets the value to the given updated value
 * if the current value {@code ==} the expected value.
 *
 * <p><a href="package-summary.html#weakCompareAndSet">May fail
 * spuriously and does not provide ordering guarantees</a>, so is
 * only rarely an appropriate alternative to {@code compareAndSet}.
 *
 * @param expect the expected value
 * @param update the new value
 * @return {@code true} if successful
 */
public final boolean weakCompareAndSet(int expect, int update) {
    return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
}e); }

这两个方法的具体区别我还没有搞清楚,只能先给大家两个参考链接了,虽然我个人认为第一个链接里讲的未必正确...

weakCompareAndSet:https://www.jianshu.com/p/55a66113bc54

happens-before:https://www.jianshu.com/p/9464bf340234

@HotSpotIntrinsicCandidate:https://blog.csdn.net/a772304419/article/details/100121143

五、其他

1、toString()
public String toString() {
    return Integer.toString(get());
}
2、其他继承自Number类的方法
public int intValue() {
    return get();
}

public long longValue() {
    return (long)get();
}

public float floatValue() {
    return (float)get();
}

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