CAS你知道嗎?原子類AtomicInteger的ABA問題談談?


(1)CAS是什么?

       比較並交換

     舉例1,  CAS產生場景代碼?

import java.util.concurrent.atomic.AtomicInteger;

public class CASDemo {
    public static void main(String[] args) {
        AtomicInteger atomicInteger=new AtomicInteger(5);//主物理內存
        //比較5
        System.out.println(atomicInteger.compareAndSet(5, 2019)+"\t current data(主物理內存) : "+ atomicInteger.get());
        //修改失敗
        System.out.println(atomicInteger.compareAndSet(5, 1024)+"\t current data(主物理內存) : "+ atomicInteger.get());
    }
}

   舉例2,  CAS產生場景代碼?原子引用

public class CAS_ABADemo {
    public static void main(String[] args) {

        //========================原子引用==========================
        User A = new User("A", 123);
        User B = new User("B", 456);
        //主物理內存 引用比較的是地址
        AtomicReference<User> atomicReference1 = new AtomicReference<>();
        atomicReference1.set(A);
        System.out.println(atomicReference1.compareAndSet(A, B) + "\t" + atomicReference1.get().toString());
        System.out.println(atomicReference1.compareAndSet(A, B) + "\t" + atomicReference1.get().toString());
    }
}
class User {
    String name;
    int age;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public User() {
    }

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

    @Override
    public String toString() {
        return "User{" +
                "name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}
原子引用

   參考博客:CopyOnWriteArrayList  寫時復制----------https://www.cnblogs.com/huangjuncong/p/9160713.html

   參考博客:ReentrantLock 獨占鎖(可重入鎖)----------https://www.cnblogs.com/takumicx/p/9338983.html

舉例3,ABA問題的產生和解決方案代碼場景。

public class ABADemo {
    static AtomicReference<Integer> atomicReference = new AtomicReference<>(100);
    static AtomicStampedReference<Integer> atomicStampedReference = new AtomicStampedReference<>(100, 1);
    public static void main(String[] args) {
        System.out.println("======ABA問題的產生======");

        new Thread(() -> {
            atomicReference.compareAndSet(100, 101);
            atomicReference.compareAndSet(101, 100);
        }, "t1").start();

        new Thread(() -> {
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();

            }
            System.out.println(atomicReference.compareAndSet(100, 2019) + "\t" + atomicReference.get().toString());
        }, "t2").start();

        try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { e.printStackTrace(); }

        System.out.println("======ABA問題的解決======");
        new Thread(() -> {
            int stamp = atomicStampedReference.getStamp();
            System.out.println(Thread.currentThread().getName() + "\t第一次版本號: " + stamp);
            try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
            atomicStampedReference.compareAndSet(100,101,
                    atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
            System.out.println(Thread.currentThread().getName() + "\t第二次版本號: " + atomicStampedReference.getStamp());
            atomicStampedReference.compareAndSet(101,100,
                    atomicStampedReference.getStamp(),atomicStampedReference.getStamp()+1);
            System.out.println(Thread.currentThread().getName() + "\t第三次版本號: " + atomicStampedReference.getStamp());
        }, "t3").start();

        new Thread(() -> {
            int stamp = atomicStampedReference.getStamp();
            System.out.println(Thread.currentThread().getName() + "\t第一次版本號: " + stamp);
            try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
            boolean result=atomicStampedReference.compareAndSet(100,2019,
                    stamp,stamp+1);
            System.out.println(Thread.currentThread().getName()+"\t修改成功與否:"+result+"  當前最新版本號"+atomicStampedReference.getStamp());
            System.out.println(Thread.currentThread().getName()+"\t當前實際值:"+atomicStampedReference.getReference());
        }, "t4").start();
    }
}
ABA問題的產生和解決方案

(3)CAS實現原子操作的三大問題。

     CAS雖然采用自旋的方式高效的解決了原子操作,但任然存在三個問題.

  1. ABA問題。
  2. 循環時間長開銷大。
  3. 只能保證一個共享變量的原子操作。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM