锟斤拷锟斤拷位锟矫ｏ拷锟斤拷页 > 锟斤拷锟斤拷锟教筹拷 > 锟教筹拷 > 学习Java锟斤拷锟斤拷锟斤拷锟斤拷械锟紸tomic原锟接匡拷

学习Java锟斤拷锟斤拷锟斤拷锟斤拷械锟紸tomic原锟接匡拷

锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷|锟斤拷时锟戒：2024-05-21 09:46:03 |锟斤拷锟侥讹拷锟斤拷137锟斤拷|锟斤拷锟斤拷签锟斤拷 T MIC VA Ato AVA v S C 锟姐法锟斤拷锟� AV java 锟斤拷 |锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

一锟斤拷写锟节匡拷头锟斤拷前锟斤拷牟锟斤拷锟斤拷锟斤拷锟斤拷锟窖帮拷锟絭olatile锟截硷拷锟街ｏ拷知锟斤拷锟斤拷锟斤拷锟斤拷锟皆憋拷证锟斤拷锟斤拷锟皆和可硷拷锟皆ｏ拷锟斤拷锟睫凤拷锟斤拷锟斤拷原锟斤拷锟皆ｏ拷锟斤拷锟皆拷锟斤拷锟斤拷锟斤拷锟斤拷萍锟绞癸拷锟絪ynchronized锟斤拷Lock锟斤拷锟斤拷AtomicInteger锟斤拷锟斤拷锟角伙拷学习锟斤拷CAS锟姐法锟斤拷锟斤拷锟斤拷篇锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷同锟斤拷也锟结及atomic锟斤拷锟斤拷么锟斤拷锟届，锟斤拷锟角撅拷锟斤拷锟矫猴拷学一学Atom

锟斤拷之前锟侥诧拷锟斤拷锟叫ｏ拷锟斤拷锟斤拷锟窖撅拷学习锟斤拷volatile锟截硷拷锟街ｏ拷锟剿解到锟斤拷锟斤拷锟皆憋拷证锟斤拷锟斤拷锟皆和可硷拷锟皆ｏ拷锟斤拷锟睫凤拷锟斤拷锟斤拷原锟斤拷锟皆★拷锟斤拷锟皆拷锟斤拷锟斤拷锟斤拷锟绞憋拷锟斤拷萍锟绞癸拷锟絪ynchronized锟斤拷Lock锟斤拷锟斤拷AtomicInteger锟斤拷锟斤拷锟角伙拷学习锟斤拷CAS锟姐法锟斤拷锟结及锟斤拷atomic锟斤拷锟斤拷锟届，锟斤拷锟角斤拷锟斤拷锟斤拷学习Atomic原锟接库，锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷CAS锟姐法实锟街的革拷效锟斤拷锟斤拷锟斤拷锟竭库。

锟斤拷锟斤拷锟斤拷java.util.concurrent锟斤拷原锟斤拷锟洁都锟斤拷锟斤拷锟絡ava.util.concurrent.atomic锟叫★拷锟斤拷锟斤拷图锟斤拷示锟斤拷

学习Java并发编程中的Atomic原子库

一锟斤拷Atomic锟斤拷锟斤拷

Atomic锟斤拷锟斤拷为锟斤拷原锟接★拷锟斤拷锟斤拷为原锟接ｏ拷锟节伙拷学锟斤拷锟斤拷锟皆拷颖锟斤拷锟轿拷枪锟斤拷苫锟窖э拷锟接︼拷锟斤拷锟叫∥拷锟斤拷锟斤拷樱锟斤拷遣锟斤拷煞指锟斤拷锟斤拷小锟斤拷位锟斤拷伟锟斤拷锟紻oug Lea锟斤拷师锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷一些锟斤拷锟皆此碉拷锟绞匡拷头锟斤拷锟斤拷锟斤拷一锟斤拷锟叫的ｏ拷

原锟斤拷锟斤拷锟节筹拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟剿硷拷牵锟揭伙拷锟斤拷锟斤拷叨锟斤拷锟斤拷锟斤拷锟斤拷CPU执锟叫的癸拷锟斤拷锟叫诧拷锟斤拷锟叫断碉拷锟斤拷锟皆★拷
原锟接诧拷锟斤拷锟节筹拷锟斤拷锟叫憋拷锟斤拷锟斤拷锟剿硷拷牵锟斤拷锟斤拷锟叫★拷锟斤拷刹锟街的诧拷锟斤拷锟斤拷也锟斤拷锟斤拷说锟斤拷锟斤拷一锟斤拷锟斤拷始锟斤拷锟酵诧拷锟杰憋拷锟斤拷希锟街憋拷锟斤拷锟斤拷锟斤拷锟缴★拷

锟斤拷锟斤拷锟侥达拷原锟接凤拷锟斤拷

锟斤拷锟角革拷锟捷诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵匡拷锟皆斤拷JUC锟斤拷锟叫碉拷原锟斤拷锟斤拷锟斤拷锟斤拷锟铰碉拷4锟街伙拷锟街ｏ拷

2.1 锟斤拷锟斤拷锟斤拷锟斤拷

原锟接诧拷锟斤拷锟侥伙拷锟斤拷锟斤拷锟斤拷锟斤拷要锟缴凤拷为锟斤拷

AtomicBoolean锟斤拷锟斤拷锟斤拷锟斤拷原锟斤拷锟洁；
AtomicInteger锟斤拷锟斤拷锟斤拷原锟斤拷锟洁；
AtomicLong锟斤拷锟斤拷锟斤拷锟斤拷原锟斤拷锟洁；

锟斤拷锟斤拷锟街凤拷式锟矫凤拷锟斤拷锟斤拷锟斤拷同锟斤拷锟斤拷锟斤拷锟斤拷原锟接革拷锟铰的凤拷式锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷AtomicInteger为锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷使锟斤拷锟斤拷原锟斤拷锟斤拷

1锟斤拷AtomicInteger锟侥筹拷锟矫凤拷锟斤拷

public final int get() //锟斤拷取锟斤拷前锟斤拷值
public final int getAndSet(int newValue)//锟斤拷取锟斤拷前锟斤拷值锟斤拷锟斤拷锟斤拷锟斤拷为newValue
public final int getAndIncrement()//锟斤拷取锟斤拷前锟斤拷值锟斤拷锟斤拷锟斤拷锟斤拷
public final int incrementAndGet()//锟斤拷锟斤拷 1锟斤拷锟斤拷锟斤拷取锟斤拷值,注锟斤拷锟斤拷锟斤拷锟芥方锟斤拷锟斤拷锟斤拷
public final int getAndDecrement() //锟斤拷取锟斤拷前锟斤拷值锟斤拷锟斤拷锟皆硷拷
public final int getAndAdd(int delta) //锟斤拷取锟斤拷前锟斤拷值锟斤拷锟斤拷锟斤拷锟斤拷预锟节碉拷值delta
boolean compareAndSet(int expect, int update) //锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷值锟斤拷锟斤拷预锟斤拷值锟斤拷锟斤拷锟斤拷原锟接凤拷式锟斤拷锟斤拷值锟斤拷锟斤拷为锟斤拷锟斤拷值锟斤拷update锟斤拷
public final void lazySet(int newValue)//锟斤拷锟斤拷锟斤拷锟斤拷为newValue,使锟斤拷 lazySet 锟斤拷锟斤拷之锟斤拷锟斤拷艿锟斤拷锟斤拷锟斤拷锟斤拷叱锟斤拷锟街拷锟斤拷一小锟斤拷时锟斤拷锟节伙拷锟角匡拷锟皆讹拷锟斤拷锟缴碉拷值.

2锟斤拷AtomicInteger锟斤拷使锟矫帮拷锟斤拷

public class Test {
    public static void main(String[] args) {
        //锟斤拷时值
        int temvalue = 0;
        AtomicInteger i = new AtomicInteger(0);
        temvalue = i.getAndSet(3);
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:0;  i:3
        temvalue = i.getAndIncrement();
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:3;  i:4
        temvalue = i.getAndAdd(5);
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:4;  i:9
        temvalue = i.incrementAndGet();
        System.out.println("temvalue:" + temvalue + ";  i:" + i); //temvalue:10;  i:10
    }
}

锟斤拷锟斤拷锟斤拷要注锟斤拷锟揭伙拷锟斤拷锟絞etAndIncrement()锟斤拷锟斤拷锟斤拷incrementAndGet()锟斤拷一锟斤拷锟饺伙拷值锟斤拷锟斤拷锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街碉拷锟�

3锟斤拷AtomicInteger锟侥底诧拷原锟斤拷

锟斤拷锟斤拷锟斤拷getAndIncrement()为锟斤拷锟斤拷去锟斤拷锟斤拷锟斤拷锟侥底诧拷锟斤拷锟结发锟街ｏ拷锟斤拷锟节诧拷锟斤拷通锟斤拷锟斤拷锟斤拷UnSafe锟斤拷木锟教拷锟斤拷锟絞etUnsafe实锟街的★拷UnSafe锟斤拷锟斤拷CAS锟姐法锟斤拷时锟斤拷锟斤拷锟结及锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟劫碉拷锟斤拷学习锟斤拷锟斤拷锟斤拷撞锟斤拷锟酵拷锟紺AS锟斤拷原锟斤拷锟皆的斤拷锟斤拷锟斤拷锟斤拷值锟斤拷

public final int getAndIncrement() {
    // 使锟斤拷Unsafe锟斤拷锟叫碉拷getAndAddInt锟斤拷锟斤拷原锟接碉拷锟斤拷锟斤拷AtomicInteger锟侥碉拷前值
    // 锟斤拷一锟斤拷锟斤拷锟斤拷this锟斤拷AtomicInteger锟侥碉拷前实锟斤拷
    // 锟节讹拷锟斤拷锟斤拷锟斤拷valueOffset锟斤拷一锟斤拷偏锟斤拷锟斤拷锟斤拷锟斤拷指示锟斤拷AtomicInteger锟斤拷锟斤拷锟叫碉拷锟侥革拷位锟矫匡拷锟斤拷锟揭碉拷实锟绞碉拷int值
    // 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷1锟斤拷示要锟接碉拷锟斤拷前值锟较碉拷值锟斤拷锟斤拷锟斤拷锟接碉拷值锟斤拷
    // 锟剿凤拷锟斤拷锟斤拷锟截碉拷锟斤拷锟斤拷锟斤拷前锟斤拷原始值
    return unsafe.getAndAddInt(this, valueOffset, 1);
}

Unsafe 锟斤拷锟斤拷Java锟叫碉拷一锟斤拷锟斤拷锟斤拷锟洁，锟斤拷锟斤拷执锟叫低硷拷锟斤拷锟斤拷锟斤拷全锟侥诧拷锟斤拷锟斤拷getAndIncrement锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷Unsafe锟斤拷锟结供锟斤拷CAS锟斤拷Compare-And-Swap锟斤拷锟斤拷锟斤拷锟斤拷实锟斤拷原锟接碉拷increment锟斤拷锟斤拷锟斤拷CAS锟斤拷一锟街筹拷锟矫碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟节讹拷锟竭程伙拷锟斤拷锟斤拷原锟接地革拷锟斤拷值锟斤拷

2.2 锟斤拷锟斤拷锟斤拷锟斤拷

原锟接诧拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵ｏ拷锟斤拷锟皆凤拷为锟斤拷锟铰硷拷锟街ｏ拷

AtomicIntegerArray锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷原锟斤拷锟斤拷
AtomicLongArray锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷原锟斤拷锟斤拷
AtomicReferenceArray锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷原锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷同锟斤拷锟斤拷锟斤拷锟狡ｏ拷锟斤拷锟斤拷锟斤拷AtomicIntegerArray为锟斤拷锟斤拷锟斤拷锟斤拷一锟铰★拷

1锟斤拷AtomicIntegerArray锟侥筹拷锟矫凤拷锟斤拷

public final int get(int i) //锟斤拷取 index=i 位锟斤拷元锟截碉拷值
public final int getAndSet(int i, int newValue)//锟斤拷锟斤拷 index=i 位锟矫的碉拷前锟斤拷值锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷为锟斤拷值锟斤拷newValue
public final int getAndIncrement(int i)//锟斤拷取 index=i 位锟斤拷元锟截碉拷值锟斤拷锟斤拷锟矫革拷位锟矫碉拷元锟斤拷锟斤拷锟斤拷
public final int getAndDecrement(int i) //锟斤拷取 index=i 位锟斤拷元锟截碉拷值锟斤拷锟斤拷锟矫革拷位锟矫碉拷元锟斤拷锟皆硷拷
public final int getAndAdd(int i, int delta) //锟斤拷取 index=i 位锟斤拷元锟截碉拷值锟斤拷锟斤拷锟斤拷锟斤拷预锟节碉拷值
boolean compareAndSet(int i, int expect, int update) //锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷值锟斤拷锟斤拷预锟斤拷值锟斤拷锟斤拷锟斤拷原锟接凤拷式锟斤拷 index=i 位锟矫碉拷元锟斤拷值锟斤拷锟斤拷为锟斤拷锟斤拷值锟斤拷update锟斤拷
public final void lazySet(int i, int newValue)//锟斤拷锟斤拷 锟斤拷index=i 位锟矫碉拷元锟斤拷锟斤拷锟斤拷为newValue,使锟斤拷 lazySet 锟斤拷锟斤拷之锟斤拷锟斤拷艿锟斤拷锟斤拷锟斤拷锟斤拷叱锟斤拷锟街拷锟斤拷一小锟斤拷时锟斤拷锟节伙拷锟角匡拷锟皆讹拷锟斤拷锟缴碉拷值.

2锟斤拷AtomicIntegerArray锟斤拷使锟矫帮拷锟斤拷

public class Test {
    public static void main(String[] args) {
        int temvalue = 0;
        int[] nums = { 1, 2, 3, 4, 5, 6 };
        AtomicIntegerArray i = new AtomicIntegerArray(nums);
        for (int j = 0; j < nums.length; j++) {
            System.out.print(i.get(j));
        }
        System.out.println();
        temvalue = i.getAndSet(0, 2);
        System.out.println("temvalue:" + temvalue + ";  i:" + i);
        temvalue = i.getAndIncrement(0);
        System.out.println("temvalue:" + temvalue + ";  i:" + i);
        temvalue = i.getAndAdd(0, 5);
        System.out.println("temvalue:" + temvalue + ";  i:" + i);
    }
}

锟斤拷锟斤拷锟�

123456
temvalue:1;  i:[2, 2, 3, 4, 5, 6]
temvalue:2;  i:[3, 2, 3, 4, 5, 6]
temvalue:3;  i:[8, 2, 3, 4, 5, 6]

2.3 锟斤拷锟斤拷锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷锟较碉拷2锟斤拷原锟斤拷锟斤拷锟解，atomic锟斤拷锟叫伙拷锟结供锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷原锟斤拷锟洁。锟斤拷锟轿拷锟斤拷录锟斤拷郑锟�

AtomicReference锟斤拷原锟接革拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵ｏ拷使锟斤拷AtomicReference锟洁保证锟斤拷锟斤拷之锟斤拷锟皆拷锟斤拷裕锟斤拷讯锟斤拷锟斤拷锟斤拷锟脚碉拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟紺AS锟斤拷锟斤拷锟斤拷
AtomicStampedReference锟斤拷原锟接革拷锟铰达拷锟叫版本锟脚碉拷锟斤拷锟斤拷锟斤拷锟酵★拷锟斤拷锟洁将锟斤拷锟斤拷值锟斤拷锟斤拷锟矫癸拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟节斤拷锟皆拷拥母锟斤拷锟斤拷锟斤拷莺锟斤拷锟斤拷莸陌姹撅拷牛锟斤拷锟斤拷越锟斤拷使锟斤拷CAS锟斤拷锟斤拷原锟接革拷锟斤拷时锟斤拷锟杰筹拷锟街碉拷ABA锟斤拷锟解；
AtomicMarkableReference锟斤拷原锟接革拷锟铰达拷锟叫憋拷堑锟斤拷锟斤拷锟斤拷锟斤拷停锟斤拷锟斤拷嘟玝oolean锟斤拷锟斤拷锟斤拷锟斤拷霉锟斤拷锟斤拷锟斤拷锟斤拷锟�

锟斤拷锟矫凤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷一锟铰ｏ拷锟斤拷锟斤不锟斤拷赘锟斤拷锟斤拷锟斤拷锟斤拷直锟斤拷写一锟斤拷demo锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷使锟矫吧★拷

public class TestAtomicReference {

    private static AtomicReference reference = new AtomicReference<>();

    public static void main(String[] args) {
        User user1 = new User("小锟斤拷", 18);
        reference.set(user1);
        User user2 = new User("小锟斤拷",20);
        User user = reference.getAndSet(user2);
        System.out.println(user);
        System.out.println(reference.get());
    }

    static class User {
        private String userName;
        private int age;

        public User(String userName, int age) {
            this.userName = userName;
            this.age = age;
        }

        @Override
        public String toString() {
            return "User{" +
                    "userName='" + userName + '\'' +
                    ", age=" + age +
                    '}';
        }
    }
}

锟斤拷锟斤拷锟�

User{userName='小锟斤拷', age=18}
User{userName='小锟斤拷', age=20}

2.4 锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷薷锟斤拷锟斤拷锟�

锟斤拷锟斤拷原锟接革拷锟铰讹拷锟斤拷锟斤拷锟斤拷锟斤拷锟酵ｏ拷锟解，atomic锟叫伙拷锟结供锟剿革拷锟铰讹拷锟斤拷锟斤拷锟斤拷锟斤拷侄蔚锟皆拷锟斤拷啵�

AtomicIntegerFieldUpdater:原锟接革拷锟斤拷锟斤拷锟斤拷锟街段的革拷锟斤拷锟斤拷锟斤拷
AtomicLongFieldUpdater锟斤拷原锟接革拷锟铰筹拷锟斤拷锟斤拷锟街段的革拷锟斤拷锟斤拷锟斤拷
AtomicReferenceFieldUpdater锟斤拷原锟接革拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷侄蔚母锟斤拷锟斤拷锟斤拷锟�

锟斤拷锟斤拷锟揭拷拥母锟斤拷露锟斤拷锟斤拷锟斤拷锟皆ｏ拷实锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟芥几锟斤拷锟斤拷锟斤拷锟斤拷微锟斤拷锟斤拷一锟铰ｏ拷锟斤拷欧锟轿拷锟斤拷锟斤拷锟�

锟斤拷锟斤拷1??
通锟斤拷锟斤拷态锟斤拷锟斤拷newUpdater锟斤拷锟斤拷一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷要锟斤拷锟铰碉拷锟斤拷锟斤拷侄危锟�

锟斤拷锟斤拷2??
锟街段憋拷锟斤拷使锟斤拷public volatile锟斤拷锟斤拷锟斤拷锟轿ｏ拷

锟斤拷AtomicIntegerFieldUpdater为锟斤拷锟斤拷锟斤拷锟斤拷写一锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭伙拷隆锟�

public class TestAtomicIntegerFieldUpdater {
    //锟斤拷锟斤拷一锟斤拷age锟侥革拷锟斤拷锟斤拷
    private static AtomicIntegerFieldUpdater updater = AtomicIntegerFieldUpdater.newUpdater(User.class,"age");

    public static void main(String[] args) {
        User user = new User("小锟斤拷", 17);
        int oldValue = updater.getAndAdd(user, 1);
        System.out.println(oldValue);//17
        System.out.println(updater.get(user));//18
    }

    static class User {
        private String userName;
        public volatile int age;

        public User(String userName, int age) {
            this.userName = userName;
            this.age = age;
        }

        @Override
        public String toString() {
            return "User{" +
                    "userName='" + userName + '\'' +
                    ", age=" + age +
                    '}';
        }
    }

通锟斤拷AtomicIntegerFieldUpdater.newUpdater(User.class,"age")锟斤拷锟斤拷一锟斤拷age锟侥革拷锟斤拷锟斤拷锟斤拷然锟斤拷锟斤拷锟絞etAndAdd(user, 1)锟斤拷锟斤拷锟斤拷锟斤拷锟�1锟斤拷锟斤拷锟斤拷锟斤拷17锟斤拷锟轿�18锟疥。

小锟斤拷锟狡硷拷锟侥讹拷