我尝试在 Bank.transfer 中使用 synchronized
和 ReentrantLock
,但我得到如下输出:
"From 7 to 3 transfered 82.0. Total 918", "From 0 to 4 transfered 27.0. Total 973"
虽然总计必须等于 1000。请告诉我我错了什么?
public class expr {
public static Bank b = new Bank();
public static void main(String[] args) throws IOException, InterruptedException {
for (int i = 0; i < 4; i++) {
new BankTransfer();
}
}
}
public class BankTransfer implements Runnable{
public BankTransfer() {
Thread t = new Thread(this);
t.start();
}
@Override
public void run() {
while (true){
int from = (int) (expr.b.size * Math.random());
int to = (int) (expr.b.size * Math.random());
int amount = (int) (100 * Math.random());
expr.b.transfer(from, to, amount);
try {
Thread.sleep((long) (2000 * Math.random()));
} catch (InterruptedException e) {
System.out.println("Thread was interrupted!");
return;
}
}
}
}
public class Bank {
private int[] accounts;
public int size = 10;
private Lock block = new ReentrantLock();
public boolean transfer(int from, int to, double amount){
block.lock();
try{
if(accounts[from] >= amount && from != to){
accounts[from] -= amount;
System.out.println("From " + from + " to " + to + " transfered " + amount + ". Total " + getTotal());
accounts[to] += amount;
return true;
}
}finally {
block.unlock();
}
return false;
}
public Bank(){
accounts = new int[size];
for (int i = 0; i < size; ++i) {
accounts[i] = 100;
}
}
private int getTotal(){
int sum = 0;
for (int i = 0; i < size; ++i) sum += accounts[i];
return sum;
}
}
最佳答案
在完成传输的两端后计算总数...即将 System.println 移到accounts[to] += amount 之后。
关于java - 我的同步不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9152666/