package bank_locks;

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

public class Bank {
    Client[] clients;
    Random rg;
    /* ReentrantLock je "katanac", poznat i pod imenom
     * "semafora". Predstavlja softversku apstrakciju za 
     * zakljucavanje kriticnih sekcija (regiona koda
     * koji smeju da budu izvrsavani ekskluzivno od
     * jedne niti u datom momentu
     */
    ReentrantLock lock;
    
    public Bank() {
	rg=new Random();
	lock=new ReentrantLock();
	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();
    }
    
    /* nakon primene zakljucavanja, vise nema problema
     * sa integritetom podataka, ukupna suma je uvek 10000
     */
    void transfer(int from, int to, int amount){
	/* kada nit izvrsava kriticnu sekciju ona
	 * je prvo zakljuca kako druge niti ne bi mogle
	 * da udju. Ispod zita se zapravo desava da postoji
	 * binarna promenljiva koja postane 0 ukoliko je
	 * nit usla u kriticnu sekciju, a kada izadje vraca
	 * se na 1, kako bi druga nit mogla da udje. Ovo moze
	 * da bude postavljeno i obrnuto (0 kada je slobodno,
	 * 1 za zauzeto, stvar implementacije).
	 */
	lock.lock();
	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());
	/* otkljucavamo da bi i neka druga nit mogla da udje */
	lock.unlock();
    }
    
    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();
	    }
        }
    }
}