线程 Atomic变量自增运算测试

xiaoxiao2021-02-28  91

public class AtomicTest{ public static AtomicInteger race=new AtomicInteger(0); public static int j=0; public static void increase(){ int t=race.incrementAndGet(); j++; System.out.println("incrementAndGet "+t+" "+j); System.out.println("thread "+Thread.currentThread()); } private static final int THREADS_COUNT=20; public static void main(String[]args)throws Exception{ Thread[]threads=new Thread[THREADS_COUNT]; for(int i=0;i<THREADS_COUNT;i++){ threads[i]=new Thread(new Runnable(){ @Override public void run() { for(int i=0;i<10000;i++){ increase(); System.out.println(); } } }); threads[i].start(); } while(Thread.activeCount()>1) Thread.yield(); System.out.println(race); }

}

incrementAndGet()方法在一个无限循环中,不断尝试将一个比当前值大1的新值赋给 自己。如果失败了,那说明在执行“获取-设置”操作的时候值已经有了修改,于是再次循环 进行下一次操作,直到设置成功为止。 尽管CAS看起来很美,但显然这种操作无法涵盖互斥同步的所有使用场景,并且CAS从 语义上来说并不是完美的,存在这样的一个逻辑漏洞:如果一个变量V初次读取的时候是A 值,并且在准备赋值的时候检查到它仍然为A值,那我们就能说它的值没有被其他线程改变 过了吗?如果在这段期间它的值曾经被改成了B,后来又被改回为A,那CAS操作就会误认 为它从来没有被改变过。这个漏洞称为CAS操作的“ABA”问题。J.U.C包为了解决这个问题, 提供了一个带有标记的原子引用类“AtomicStampedReference”,它可以通过控制变量值的版本 来保证CAS的正确性。不过目前来说这个类比较“鸡肋”,大部分情况下ABA问题不会影响程 序并发的正确性,如果需要解决ABA问题,改用传统的互斥同步可能会比原子类更高效。

转载请注明原文地址: https://www.6miu.com/read-85701.html

最新回复(0)