一、需求描述:
将资金从一个账户转移到另一个账户。
二、程序实现:
(1)账户类:
public class Account {
private long account; public Account(String user, long account) {
this.account = account;
} public Account() {
super();
} public long getAccount() {
return account;
} public void setAccount(long account) {
this.account = account;
} public void debit(long money){
this.account -= money;
} public void credit(long money){
this.account += money;
}
}
(2)资产转移类:
public class TransMoney {
private static final Object tieLock = new Object();
public static void transferMoney(Account fromAccount,Account toAccount,long amount){
synchronized (fromAccount){
synchronized (toAccount){
fromAccount.debit(amount);
toAccount.credit(amount);
}
}
}
}
(3)测试类:
public class DemonstrateDeadLock {
private static final int NUM_THREADS = 20;
private static final int NUM_ACCOUNTS = 5;
private static final int NUM_ITERATIONS = 1000000; public static void main(String[] args) {
final Random rdn = new Random();
final Account[] accounts = new Account[NUM_ACCOUNTS]; for(int i=0;i<accounts.length;i++){
accounts[i] = new Account();
} class TransferThread extends Thread{
public void run(){
for(int i=0;i<NUM_ITERATIONS;i++){
int fromAccount = rdn.nextInt(NUM_ACCOUNTS);
int toAccount = rdn.nextInt(NUM_ACCOUNTS); TransMoney.transferMoney(accounts[fromAccount],accounts[toAccount],rdn.nextInt(1000));
}
}
} for(int i=0;i<NUM_THREADS;i++){
new TransferThread().start();
}
}
}
(4)解析:
上述程序容易形成死锁,原因在于多账户调用TransMoney.transferMoney时,存在锁顺序冲突,
解决方案是使用System.identityHashCode来定义锁的顺序,消除死锁的可能性,代码实现如下:
public static void transferMoney(final Account fromAccount,final Account toAccount,final long amount){
class Helper{
public void transfer(){
fromAccount.debit(amount);
toAccount.credit(amount);
}
} int fromHash = System.identityHashCode(fromAccount);
int toHash = System.identityHashCode(toAccount);
if(fromHash < toHash){
synchronized (fromAccount){
synchronized (toAccount){
new Helper().transfer();
}
}
}else if(fromHash > toHash){
synchronized (toAccount){
synchronized (fromAccount){
new Helper().transfer();
}
}
}else{
synchronized (tieLock){
synchronized (fromAccount){
synchronized (toAccount){
new Helper().transfer();
}
}
}
}
}