【实战Java高并发程序设计3】带有时间戳的对象引用:AtomicStampedReference

王朝学院·作者佚名  2016-08-27
窄屏简体版  字體: 小  |  中  |  大  |  超大  

【实战java高并发程序设计 1】Java中的指针:Unsafe类

【实战Java高并发程序设计 2】无锁的对象引用:AtomicReference

AtomicReference无法解决上述问题的根本是因为对象在修改过程中,丢失了状态信息。对象值本身与状态被画上了等号。因此,我们只要能够记录对象在修改过程中的状态值,就可以很好的解决对象被反复修改导致线程无法正确判断对象状态的问题。

AtomicStampedReference正是这么做的。它内部不仅维护了对象值,还维护了一个时间戳(我这里把它称为时间戳,实际上它可以使任何一个整数,它使用整数来表示状态值)。当AtomicStampedReference对应的数值被修改时,除了更新数据本身外,还必须要更新时间戳。当AtomicStampedReference设置对象值时,对象值以及时间戳都必须满足期望值,写入才会成功。因此,即使对象值被反复读写,写回原值,只要时间戳发生变化,就能防止不恰当的写入。

AtomicStampedReference的几个API在AtomicReference的基础上新增了有关时间戳的信息:

//比较设置 参数依次为:期望值 写入新值 期望时间戳 新时间戳publicbooleancompareAndSet(V expectedReference,V

newReference,intexpectedStamp,intnewStamp)//获得当前对象引用publicV getReference()//获得当前时间戳publicintgetStamp()//设置当前对象引用和时间戳publicvoidset(V newReference,intnewStamp)

有了AtomicStampedReference这个法宝,我们就再也不用担心对象被写坏啦!现在,就让我们使用AtomicStampedReference在修正那个贵宾卡充值的问题的:

01publicclassAtomicStampedReferenceDemo {02staticAtomicStampedReference<Integer> money=newAtomicStampedReference<Integer>(19,0);03publicstaticvoid main(String[] args) {04//模拟多个线程同时更新后台数据库,为用户充值05for(inti = 0 ; i < 3 ; i++) {06finalinttimestamp=money.getStamp();07newThread() {08publicvoidrun() {09while(true){10while(true){11 Integerm=money.getReference();12if(m<20){13if(money.compareAndSet(m,m+20,timestamp,timestamp+1)){14 System.out.PRintln("余额小于20元,充值成功,余额:"+money.getReference()+"元");15

break;16}17 }else{18//System.out.println("余额大于20元,无需充值");19

break;20}21}22}23}24}.start();25}26

27//用户消费线程,模拟消费行为28newThread() {29publicvoid run() {30for(inti=0;i<100;i++){31while(true){32inttimestamp=money.getStamp();33 Integer m=money.getReference();34if(m>10){35 System.out.println("大于10元");36if(money.compareAndSet(m, m-10,timestamp,timestamp+1)){37 System.out.println("成功消费10元,余额:"+money.getReference());38

break;39}40 }else{41 System.out.println("没有足够的金额");42

break;43}44}45try{Thread.sleep(100);}catch(InterruptedException e) {}46}47}48}.start();49}50 }

第2行,我们使用AtomicStampedReference代替原来的AtomicReference。第6行获得账户的时间戳。后续的赠予操作以这个时间戳为依据。如果赠予成功(13行),则修改时间戳。使得系统不可能发生二次赠予的情况。消费线程也是类似,每次操作,都使得时间戳加1(36行),使之不可能重复。

执行上述代码,可以得到以下输出:

余额小于20元,充值成功,余额:39元

大于10元

成功消费10元,余额:29

大于10元

成功消费10元,余额:19

大于10元

成功消费10元,余额:9

没有足够的金额

可以看到,账户只被赠予了一次。

【实战Java高并发程序设计 1】Java中的指针:Unsafe类

【实战Java高并发程序设计 2】无锁的对象引用:AtomicReference

摘自:实战Java高并发程序设计

 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
© 2005- 王朝網路 版權所有 導航