gistfile1.txt

package ru.tfs.concurrency.task2;

import java.util.concurrent.Exchanger;
import java.util.concurrent.locks.ReentrantLock;

public class AccountThread implements Runnable {
//    private static final ReentrantLock lock = new ReentrantLock(true);
    private static final Object lock = new Object();
    private final Account accountFrom;
    private final Account accountTo;
    private final int money;

    public AccountThread(Account accountFrom, Account accountTo, int money) {
        this.accountFrom = accountFrom;
        this.accountTo = accountTo;
        this.money = money;
    }

    @Override
    public void run() {
        for (int i = 0; i < 4000; i++) {
            synchronized (lock) {
                boolean goodTransaction = accountFrom.takeOffMoney(money);
                System.out.println("Transaction status: " + goodTransaction);

                if (!goodTransaction) {
                    throw new RuntimeException("Account from balance became negative");
                }

                accountTo.addMoney(money);

                System.out.println("Cash balance of the first account: " + accountFrom.getCacheBalance());
                System.out.println("Cash balance of the second account: " + accountTo.getCacheBalance());
                System.out.println("-----");
            }
        }
    }
}