摘要：有时候，由于初期考虑不周，或者后期的需求变化，一些普通变量可能也会有线程安全的需求。它可以让你在不改动或者极少改动原有代码的基础上，让普通的变量也享受操作带来的线程安全性，这样你可以修改极少的代码，来获得线程安全的保证。
有时候，由于初期考虑不周，或者后期的需求变化，一些普通变量可能也会有线程安全的需求。如果改动不大，我们可以简单地修改程序中每一个使用或者读取这个变量的地方。但显然，这样并不符合软件设计中的一条重要原则——开闭原则。也就是系统对功能的增加应该是开发的，而对修改应该是相对保守的。而且，如果系统里使用到这个变量的地方特别多，一个一个修改也是一件令人厌烦的事情（况且很多使用场景下可能只是只读的，并无线程安全的强烈要求，完全可以保持原样）。
如果你有这种困扰，在这里根本不需要担心，因为在原子包里还有一个实用的工具类AtomicIntegerFieldUpdater。它可以让你在不改动（或者极少改动）原有代码的基础上，让普通的变量也享受CAS操作带来的线程安全性，这样你可以修改极少的代码，来获得线程安全的保证。这听起来是不是让人很激动呢？
根据数据类型不同，这个Updater有3种，分别是AtomicIntegerFieldUpdater、AtomicLongFieldUpdater和AtomicReferenceFieldUpdater。顾名思义，它们分别可以对int、long和普通对象就行CAS修改。
现在来思考这么一个场景。假设某地要进行一次选举。现在模拟这个机票场景，如果选民投了候选人一票，就记为1，否则记为0。最终的选票显然就是所有数据的简单求和。
01 public class AtomicIntegerFieldUpdaterDemo {
02 public static class Candidate{
03 int id;
04 volatile int score;
05 }
06 public final static AtomicIntegerFieldUpdater scoreUpdater
07 = AtomicIntegerFieldUpdater.newUpdater(Candidate.class, "score");
08 //检查Updater是否工作正确
09 public static AtomicInteger allScore=new AtomicInteger(0);
10 public static void main(String[] args) throws InterruptedException {
11 final Candidate stu=new Candidate();
12 Thread[] t=new Thread[10000];
13 for(int i = 0 ; i < 10000 ; i++) {
14 t[i]=new Thread() {
15 public void run() {
16 if(Math.random()>0.4){
17 scoreUpdater.incrementAndGet(stu);
18 allScore.incrementAndGet();
19 }
20 }
21 };
22 t[i].start();
23 }
24 for(int i = 0 ; i < 10000 ; i++) { t[i].join();}
25 System.out.println("score="+stu.score);
26 System.out.println("allScore="+allScore);
27 }
28 }
上述代码模拟了这个计票场景。候选人的得票数量记录在Candidate.score中。注意，它是一个普通的volatile变量。而volatile变量并不是线程安全的。第6~7行定义了
AtomicIntegerFieldUpdater实例，用来对Candidate.score进行写入。而后续的allScore我们用来检查AtomicIntegerFieldUpdater的正确性。如果AtomicIntegerFieldUpdater真的保证了线程安全，那么最终Candidate.score和allScore的值必然是相等的。否则，就说明AtomicIntegerFieldUpdater根本没有确保线程安全的写入。第12~21行模拟了计票过程，这里假设有大约60%的人投赞成票，并且投票是随机进行的。第17行使用Updater修改Candidate.score（这里应该是线程安全的），第18行使用AtomicInteger计数，作为参考基准。
大家如果运行这段程序，不难发现，最终的Candidate.score总是和allScore绝对相等。这说明AtomicIntegerFieldUpdater很好地保证了Candidate.score的线程安全。
虽然AtomicIntegerFieldUpdater很好用，但是还是有几个注意事项：
第一，Updater只能修改它可见范围内的变量。因为Updater使用反射得到这个变量。如果变量不可见，就会出错。比如如果score申明为private，就是不可行的。
第二，为了确保变量被正确的读取，它必须是volatile类型的。如果我们原有代码中未申明这个类型，那么简单得申明一下就行，这不会引起什么问题。
第三，由于CAS操作会通过对象实例中的偏移量直接进行赋值，因此，它不支持static字段（Unsafe. objectFieldOffset()不支持静态变量）。
好了，通过AtomicIntegerFieldUpdater，是不是让我们可以更加随心所欲得对系统关键数据进行线程安全地保护呢？
【实战Java高并发程序设计1】Java中的指针：Unsafe类
【实战Java高并发程序设计2】无锁的对象引用：AtomicReference
【实战Java高并发程序设计 3】带有时间戳的对象引用：AtomicStampedReference
【实战Java高并发程序设计 4】数组也能无锁AtomicIntegerArray
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/65622.html
摘要：在本例中，讲述的无锁来自于并发包我们将这个无锁的称为。在这里，我们使用二维数组来表示的内部存储，如下变量存放所有的内部元素。为什么使用二维数组去实现一个一维的呢这是为了将来进行动态扩展时可以更加方便。 我们已经比较完整得介绍了有关无锁的概念和使用方法。相对于有锁的方法，使用无锁的方式编程更加考验一个程序员的耐心和智力。但是，无锁带来的好处也是显而易见的，第一，在高并发的情况下，它比有锁...
摘要：参考何去何从的并行计算忘记该死的并行并行程序的复杂性和乱序性，并行程序设计十分复杂。可怕的现实摩尔定律的失效单核上的晶体管数目达到极限。并发级别阻塞重入锁无饥饿两个线程优先级不同，低优先级的可能产生饥饿。 Chapter1 参考：https://github.com/chengbingh... 1.1何去何从的并行计算 1.1.1 忘记该死的并行并行程序的复杂性和乱序性，并行程序设计十...
摘要：通过指令重排可以减少流水线停顿提升巨大效率原则程序顺序原则一个线程内保证语义的串行性。锁规则解锁必然发生在随后的加锁前。线程的方法先于它的每一个动作。 1. 基本概念 同步(Synchronous)和异步(Asynchronous) 并发(Conncurrency)和并行(Parallelism) 临界区 阻塞(Blocking)与非阻塞(Non-Blocking) 死锁(Deadl...
摘要：当前可用的原子数组有和，分别表示整数数组型数组和普通的对象数组。摘自实战高并发程序设计一书实战高并发程序设计中的指针类实战高并发程序设计无锁的对象引用实战高并发程序设计带有时间戳的对象引用 除了提供基本数据类型外，JDK还为我们准备了数组等复合结构。当前可用的原子数组有：AtomicIntegerArray、AtomicLongArray和AtomicReferenceArray，分别...
阅读 2884·2023-04-26 01:49
阅读 2040·2021-10-13 09:39
阅读 2235·2021-10-11 11:09
阅读 876·2019-08-30 15:53
阅读 2792·2019-08-30 15:44
阅读 902·2019-08-30 11:12
阅读 2899·2019-08-29 17:17
阅读 2334·2019-08-29 16:57
