问个thread synchronization的问题# JobHunting - 待字闺中
r*e
1 楼
void transaction(Account a, Account b, double amount)
想从a 转钱到b。怎么设计实现efficient的synchronization。
code in java
想从a 转钱到b。怎么设计实现efficient的synchronization。
code in java
g*e
2 楼
read java concurrancy in practice
efficient事小，dead lock事大
【在 r**e 的大作中提到】
: void transaction(Account a, Account b, double amount)
: 想从a 转钱到b。怎么设计实现efficient的synchronization。
: code in java
efficient事小，dead lock事大
【在 r**e 的大作中提到】
: void transaction(Account a, Account b, double amount)
: 想从a 转钱到b。怎么设计实现efficient的synchronization。
: code in java
r*e
3 楼
当然，潜在的问题是，设计的方法不能有deadlock。
r*e
4 楼
顺便问个keyword final的问题。
为什么local variable 使用final之后，就可以被inner class使用了？
为什么local variable 使用final之后，就可以被inner class使用了？
r*e
5 楼
他说efficient的意思是不让直接用 synchronized modify 这个method
【在 g**e 的大作中提到】
: read java concurrancy in practice
: efficient事小，dead lock事大
【在 g**e 的大作中提到】
: read java concurrancy in practice
: efficient事小，dead lock事大
g*e
6 楼
http://mitbbs.com/article1/Java/31120293_3_0.html
【在 r**e 的大作中提到】
: 顺便问个keyword final的问题。
: 为什么local variable 使用final之后，就可以被inner class使用了？
【在 r**e 的大作中提到】
: 顺便问个keyword final的问题。
: 为什么local variable 使用final之后，就可以被inner class使用了？
r*e
7 楼
I saw this. But honestly, I am not convinced by his answer.
【在 g**e 的大作中提到】
: http://mitbbs.com/article1/Java/31120293_3_0.html
【在 g**e 的大作中提到】
: http://mitbbs.com/article1/Java/31120293_3_0.html
g*e
8 楼
then u should see goodbug's answer too.
that is the correct answer.
【在 r**e 的大作中提到】
: I saw this. But honestly, I am not convinced by his answer.
that is the correct answer.
【在 r**e 的大作中提到】
: I saw this. But honestly, I am not convinced by his answer.
g*e
9 楼
barcap这么多年还在问这个题？
【在 r**e 的大作中提到】
: 他说efficient的意思是不让直接用 synchronized modify 这个method
【在 r**e 的大作中提到】
: 他说efficient的意思是不让直接用 synchronized modify 这个method
s*n
10 楼
答案是什么？我想用spinlock但是估计 不对。
【在 g**e 的大作中提到】
: barcap这么多年还在问这个题？
【在 g**e 的大作中提到】
: barcap这么多年还在问这个题？
g*e
11 楼
这题怎么用lock free的方法做我不会，我觉得必须要用synchronize。为了避免dead
lock可以比较两个account的identityHashCode，保证每次锁的顺序一样。
lock free的方法请大牛来解答
【在 s*****n 的大作中提到】
: 答案是什么？我想用spinlock但是估计 不对。
lock可以比较两个account的identityHashCode，保证每次锁的顺序一样。
lock free的方法请大牛来解答
【在 s*****n 的大作中提到】
: 答案是什么？我想用spinlock但是估计 不对。
a*2
12 楼
compare and swap?
g*s
13 楼
that's enough.
除非需要毫秒级的latency，否则这里没有必要用lockfree
【在 g**e 的大作中提到】
: 这题怎么用lock free的方法做我不会，我觉得必须要用synchronize。为了避免dead
: lock可以比较两个account的identityHashCode，保证每次锁的顺序一样。
: lock free的方法请大牛来解答
除非需要毫秒级的latency，否则这里没有必要用lockfree
【在 g**e 的大作中提到】
: 这题怎么用lock free的方法做我不会，我觉得必须要用synchronize。为了避免dead
: lock可以比较两个account的identityHashCode，保证每次锁的顺序一样。
: lock free的方法请大牛来解答
g*e
14 楼
抛砖引玉，写了一个lock free的，经grass的指点，终于写对了...
class Account {
private final AtomicLong value = new AtomicLong();
public Account(double b) {
this.value.set(Double.doubleToLongBits(b));
}
public double getBalance() {
return Double.longBitsToDouble(value.get());
}
public void transferMoneyLockFree(double amount) {
while (true) {
double oldBalance = this.getBalance();
double newBalance = amount+oldBalance;
if (amount<0 && newBalance<0)
throw new IllegalArgumentException("can't
transfer "+ amount+". Not enough balance");
if (value.compareAndSet(Double.doubleToLongBits(
oldBalance), Double.doubleToLongBits(newBalance)))
break;
}
}
}
public final class TransferFundsBetweenAccounts {
public static final void transferFund(Account from, Account to,
double amount) {
if (amount==0)
return;
if (amount<0) {
transferFund(to, from, -amount);
return;
}
try {
from.transferMoneyLockFree(-amount);
to.transferMoneyLockFree(amount);
} catch (IllegalArgumentException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws InterruptedException {
final Account a = new Account(1000);
final Account b = new Account(1000);
ExecutorService exec = Executors.newCachedThreadPool();
int n = 1000;
long t = System.currentTimeMillis();
for(int i=0; i
public void run() {
TransferFundsBetweenAccounts.
transferFund(a, b, 1);
}
});
for(int i=0; i
public void run() {
TransferFundsBetweenAccounts.
transferFund(b, a, 1);
}
});
exec.shutdown();
exec.awaitTermination(10, TimeUnit.SECONDS);
t = System.currentTimeMillis() - t;
System.out.println("balance of a = " + a.getBalance());
System.out.println("balance of b = " + b.getBalance());
System.out.println("run time = " + t + " mili sec");
}
}
dead
【在 g***s 的大作中提到】
: that's enough.
: 除非需要毫秒级的latency，否则这里没有必要用lockfree
class Account {
private final AtomicLong value = new AtomicLong();
public Account(double b) {
this.value.set(Double.doubleToLongBits(b));
}
public double getBalance() {
return Double.longBitsToDouble(value.get());
}
public void transferMoneyLockFree(double amount) {
while (true) {
double oldBalance = this.getBalance();
double newBalance = amount+oldBalance;
if (amount<0 && newBalance<0)
throw new IllegalArgumentException("can't
transfer "+ amount+". Not enough balance");
if (value.compareAndSet(Double.doubleToLongBits(
oldBalance), Double.doubleToLongBits(newBalance)))
break;
}
}
}
public final class TransferFundsBetweenAccounts {
public static final void transferFund(Account from, Account to,
double amount) {
if (amount==0)
return;
if (amount<0) {
transferFund(to, from, -amount);
return;
}
try {
from.transferMoneyLockFree(-amount);
to.transferMoneyLockFree(amount);
} catch (IllegalArgumentException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws InterruptedException {
final Account a = new Account(1000);
final Account b = new Account(1000);
ExecutorService exec = Executors.newCachedThreadPool();
int n = 1000;
long t = System.currentTimeMillis();
for(int i=0; i
public void run() {
TransferFundsBetweenAccounts.
transferFund(a, b, 1);
}
});
for(int i=0; i
public void run() {
TransferFundsBetweenAccounts.
transferFund(b, a, 1);
}
});
exec.shutdown();
exec.awaitTermination(10, TimeUnit.SECONDS);
t = System.currentTimeMillis() - t;
System.out.println("balance of a = " + a.getBalance());
System.out.println("balance of b = " + b.getBalance());
System.out.println("run time = " + t + " mili sec");
}
}
dead
【在 g***s 的大作中提到】
: that's enough.
: 除非需要毫秒级的latency，否则这里没有必要用lockfree
T*e
15 楼
有个小问题：
from.transferMoneyLockFree(-amount);
to.transferMoneyLockFree(amount);
这是两个transaction，如果system crash in the middle, 那么from account 里面的
钱被扣除了， 而还没有来的及转移到to account 里面。
在transferMoneyLockFree（）function里面用了while loop， 直到transfer成功为止
， system busy的时候，from和to很可能有很多lag， system crash 造成的损害就更
大了。。。
from.transferMoneyLockFree(-amount);
to.transferMoneyLockFree(amount);
这是两个transaction，如果system crash in the middle, 那么from account 里面的
钱被扣除了， 而还没有来的及转移到to account 里面。
在transferMoneyLockFree（）function里面用了while loop， 直到transfer成功为止
， system busy的时候，from和to很可能有很多lag， system crash 造成的损害就更
大了。。。
g*e
16 楼
你说的对，真正做时候，是要用transaction实现的，一出问题就roll back。
第二个问题是不存在的，cas效率很高，比synchronized快
【在 T********e 的大作中提到】
: 有个小问题：
: from.transferMoneyLockFree(-amount);
: to.transferMoneyLockFree(amount);
: 这是两个transaction，如果system crash in the middle, 那么from account 里面的
: 钱被扣除了， 而还没有来的及转移到to account 里面。
: 在transferMoneyLockFree（）function里面用了while loop， 直到transfer成功为止
: ， system busy的时候，from和to很可能有很多lag， system crash 造成的损害就更
: 大了。。。
第二个问题是不存在的，cas效率很高，比synchronized快
【在 T********e 的大作中提到】
: 有个小问题：
: from.transferMoneyLockFree(-amount);
: to.transferMoneyLockFree(amount);
: 这是两个transaction，如果system crash in the middle, 那么from account 里面的
: 钱被扣除了， 而还没有来的及转移到to account 里面。
: 在transferMoneyLockFree（）function里面用了while loop， 直到transfer成功为止
: ， system busy的时候，from和to很可能有很多lag， system crash 造成的损害就更
: 大了。。。
相关阅读
请教如何选择H1B生效日期。寻找下一个回文数Question about h1b thxAmazon offer + 面经 ... How to negotiate effectively?求祝福急问有关opt申请版上还有多少非cs科班的在苦苦准备啊请问VSC的加急的fax number是多少?What is the status of my OPT?问个公司兼并的问题礼拜五on site大家祝福下我吧求救：不用公司请的移民律师？？！！background check大概多久能clear啊?周一放假是吗？【绝无仅有的超差人品】H1B 申请了 将近11个月都没批下来！！！！！non recursive binary tree traversal in O(n) time and O(1) spaceUrgent help need: how to suspend OPT等一周没消息，是不是就没希望了？如何做好一个presentation一道CompleteBook上的SQL题