CAS无锁优化

青旅半醒 2021-07-25 01:35 452阅读 0赞

# 一 点睛 #

CAS 是 Compare And Set 的缩写。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][]

图解

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1][]

ABA 问题的解决方法是加 version。

A 1.0

B 2.0

C 3.0

cas（version）

如果是基础类型，无所谓。如果是引用类型，就可能有问题，因为别的线程可能改变了引用中的数据。

# 二 代码 #

/**
    * 解决同样的问题的更高效的方法，使用AtomXXX类
    * AtomXXX类本身方法都是原子性的，但不能保证多个方法连续调用是原子性的
    */
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicInteger;
    
    public class T01_AtomicInteger {
        /*volatile*/ //int count1 = 0;
        AtomicInteger count = new AtomicInteger(0);
    
        /*synchronized*/ void m() {
            for (int i = 0; i < 10000; i++)
                //if count1.get() < 1000
                count.incrementAndGet(); //count1++
        }
    
        public static void main(String[] args) {
            T01_AtomicInteger t = new T01_AtomicInteger();
    
            List<Thread> threads = new ArrayList<Thread>();
    
            for (int i = 0; i < 10; i++) {
                threads.add(new Thread(t::m, "thread-" + i));
            }
    
            threads.forEach((o) -> o.start());
    
            threads.forEach((o) -> {
                try {
                    o.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
    
            System.out.println(t.count);
        }
    }

# 三 测试 #

> 100000

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/556ff69bb4b141caa812647539128642.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1]: /images/20210724/3c261a86aa034b5787a9a5ecf476689b.png