问个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 造成的损害就更
: 大了。。。
相关阅读
看了这些人的收入，谁该敢说自己是高薪？ (转载)北美华人马工联合会（NACSWEA) 湾区第一次活动通告关于L家有人爆我code，亲自澄清一下。工作offer，背景调查要第三国的证明需要Linux developer[Job Referral]Datadog NYC Hiring纽约曼哈顿nyc金融科技公司提供内推我这样通过加入ICC转行可行么说说某家pip气人的地方[长期，稳定，迅速]提供Amazon内推问一个问题？fb的analytics manager 的级别和package 是什么样？我其实一直想为一家在美的中国公司工作G纽约office已过HC，求收留Re: 无耻！大弓科技又爆抄袭Uber的二逼客服也是醉了Offer 比较有没有在Austin cirrus logic的朋友，求内推“蒙面小王子”（侧田）太为码农长志了狗家 pip 策略讨论 (*bssd*)上海立信会计金融学院招聘