package bank_simple;

import java.util.Random;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class Bank {
    Client[] clients;
    Random rg;
    
    public Bank() {
	rg=new Random();
	clients=new Client[100];
	for(int i=0; i<clients.length; i++)
	    clients[i]=new Client(i,100,this);
	for(int i=0; i<clients.length; i++)
	    clients[i].start();
    }

    /* transfer metod je kljucan, jer se tu desava operacija
     * koja potencijalno moze da narusi integritet podataka.
     * Sta sve moze da se desi ako nit bude prekinuta od strane
     * druge niti u trenutku kada je izvrsila dekrementaciju, 
     * a nije jos inkrementaciju?
     * Sta se desava na mikro nivou, tj. na nivou asemblerskih 
     * instrukcija, jer nit i tu moze da bude prekinuta?
     * MUA clients[from]
     * SUB amount <- npr. sta ako je prekid ovde?
     * AUM clients[from]
     * 
     * Kada se pokrene ovaj program moze se videti da ukupan
     * zbir svih depozita nije uvek 10000, dakle integritet podataka
     * je narusen!
     */
    void transfer(int from, int to, int amount){
	//dozvoljavamo da se skida sa racuna iako nema
	//dovoljno sredstava, sa ovim cemo se pozabaviti kasnije
	clients[from].balance-=amount;
	clients[to].balance+=amount;
	System.out.printf("%d %d (%d->%d) Total: %d\n",
	    clients[from].balance,amount, from,to,total());
    }
    
    int total(){
	int total=0;
	for(int i=0; i<clients.length; i++)
	    total+=clients[i].balance;
	return total;
    }
    
    /**
     * @param args
     */
    public static void main(String[] args) {
	Bank bank=new Bank();
    }
}

class Client extends Thread{
    int id;
    int balance;
    Bank bank;
    public Client(int id, int balance, Bank bank) {
	this.id=id;
	this.balance=balance;
	this.bank=bank;
    }
    
    @Override
    public void run() {
        super.run();
        while(true){
            int to = bank.rg.nextInt(100);
            int amount = bank.rg.nextInt(100);
            bank.transfer(id, to, amount);
            try {
		sleep(10);
	    } catch (InterruptedException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	    }
        }
    }
}