一、应用场景
在通常情况下,我们在用多线程处理一个问题时,当多个线程要同时处理一个共享的数据时,往往需要通过synchronized的进行同步,在线程比较多的情况会导致锁竞争太厉害,大部分的时间都花费在了线程切换之间,而对实际的业务缺操作的相对比较少。
下面我们用java.util.concurrent.atomic来实现一个类似的功能,以银行存取款为例子:
public class AtomicAccount {
AtomicLong balance;
public AtomicAccount(long money) {
balance = new AtomicLong(money);
System.out.println("Total Money:"+balance);
}
public void deposit(long money) {
balance.addAndGet(money);
}
public void withdraw(long money,int delay) {
long oldvalue = balance.get();
if(oldvalue>=money) {
try {
Thread.sleep(delay);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
[color=red] //如果balance和oldvalue相同,则balance=oldvalue - money;
if(balance.compareAndSet(oldvalue, oldvalue - money)) {[/color]
System.out.println(Thread.currentThread().getName()+" withdraw " + money +" successfull!" + "balance="+balance);
} else {
System.out.println(Thread.currentThread().getName()+" withdraw " + money +" failed!" + "balance="+balance);
}
} else {
System.out.println(Thread.currentThread().getName()+" withdraw " + money +" balance is not enough,withdraw failed!" + "balance="+balance);
}
}
}
public class AtomicAccountTest extends Thread{
AtomicAccount account;
int delay;
public AtomicAccountTest(AtomicAccount account , int delay) {
this.account = account;
this.delay = delay;
}
public void run() {
account.withdraw(100, delay);
}
public static void main(String[] args) {
AtomicAccount account = new AtomicAccount(100);
AtomicAccountTest thread_1 = new AtomicAccountTest(account,1000);
AtomicAccountTest thread_2 = new AtomicAccountTest(account,0);
thread_1.start();
thread_2.start();
}
}
运行结果:
Total Money:100
Thread-1 withdraw 100 successfull!balance=0
Thread-0 withdraw 100 failed!balance=0
二、说明:
//如果balance和oldvalue相同,则balance=oldvalue - money;
执行到if(balance.compareAndSet(oldvalue, oldvalue - money)) 的时候,会判断balance与oldvalue是否相同,如果相同,说明没有程序篡改,则balance=oldvalue - money
分享到:
相关推荐
安全栈表实现,C++11实现,使用atomic特性,可以多线程进行操作
atomic
Atomic
Atomic CSS增量更新的设计与实现,刘灿,沈奇威,(1)针对Atomic CSS全量更新过程中耗费时间、流量较大的问题,提出一种增量更新方案。该方案将CSS内容与版本信息分别保存于浏览器Loca
Atomic Scala eBook 编程思想的作者新书
主要研究四种变量(属性)的存取速度. volatile nonatomic atomic和正常变量
描述了linux系统原子操作的实现以及使用原子操作时的注意事项。
Atomic clock radio
Atom-Atomic-Monokai-Syntax.zip,A Monokai-flavored syntax highlighting theme for Atom作为一个长期的优秀文本用户,我已经过渡到使用atom作为我的代码编辑器,虽然我喜欢它更易破解的方面,但我并没有找不到一个...
来自BOOST库的原子操作atomic的源代码,跨平台
前端开源库-atomic-batcher原子批处理程序,一个简单的批处理函数,允许您自动批处理一系列操作。
不错的时钟工具,带闹铃,日历,可置顶 Atomic Alarm Clock.rar
Chronograph Atomic Time Clock 6.40(校时原子钟的时间工具)英文绿色特别版
ATOMIC:an atlas of machine commonsense for if-then reasoning中的数据集
Atomic bitops based version of ext2 atomic bitops.
angular-atomic-notify, angular.js 应用程序的原子咆哮通知 angular-atomic-notify一个用于显示通知的AngularJS模块 依赖项我们使用这个库作为示例,注意jQuery用于 angular.element 和 Font Awesome 图标,但是你...
ZooKeeper’s atomic broadcast protocol 翻译版
dll控件常规安装方法(仅供参考): 一、如果在运行某软件或编译程序时提示缺少、找不到dll等类似提示,您可将下载来的dll拷贝到指定目录即可(一般是system系统目录或放到软件同级目录里面),或者重新添加文件引用...
scala 编程思想 书籍中的源码,免费下载供大家使用