package solutions.locks;

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

import os.simulation.Application;
import os.simulation.AutoCreate;
import os.simulation.Container;
import os.simulation.Item;
import os.simulation.Operation;
import os.simulation.Thread;

/*
 * U frizerskom salonu rade dva berberina. Ako nema musterija, berber sedi u
 * svojoj stolici i spava. Kada musterija udje, ako neki od berbera spava, budi
 * ga, seda za stolicu i berber je sisa. Ako su svi berberi zauzeti, musterija
 * seda za stolicu u cekaonici i ceka da se oslobodi neko od berbera. Kada
 * berber zavrsi sisanje musterije, ako ima musterija koje cekaju, krece da
 * sisa jednu od musterija koje cekaju. Ako nema vise musterija koje cekaju,
 * berber seda u svoju stolicu i spava.
 *
 * Implementirati sinhronizaciju ove dve vrste procesa kako je opisano.
 */

public class UspavaniBerberiBrave extends Application{

	private class Pristup{
		private Lock lock = new ReentrantLock() ;
		private Condition uslovZaBerbere = lock.newCondition();
		private Condition uslovZaMusterije = lock.newCondition();

		private int brojacBerbera = 0 ;
		private int brojacMusterija = 0 ;

		private void sacekajBerbera() throws InterruptedException {
			lock.lock();
			try {
				while(brojacBerbera == 0 )
					uslovZaMusterije.await();

				brojacMusterija++;
				brojacBerbera--;
				uslovZaBerbere.signal();


			}finally {
				lock.unlock();
			}
		}

		private void sacekajMusteriju() throws InterruptedException {
			lock.lock();
			try {

				brojacBerbera++;
				uslovZaMusterije.signal();

				while(brojacMusterija == 0)
					uslovZaBerbere.await();

				brojacMusterija--;


			}finally {
				lock.unlock();
			}
		}




	}

	private Pristup pristup = new Pristup();

	@AutoCreate(2)
	protected class Berber extends Thread {

		@Override
		protected void step() {
			try {
				pristup.sacekajMusteriju();
				sisa();

			} catch (InterruptedException e) {

			}

		}
	}

	@AutoCreate
	protected class Musterija extends Thread {

		@Override
		protected void run() {
			try {
				pristup.sacekajBerbera();
				sisaSe();

			} catch (InterruptedException e) {

			}

		}
	}

	// ------------------- //
	//    Sistemski deo    //
	// ------------------- //
	// Ne dirati kod ispod //
	// ------------------- //

	protected final Container cekaonica = box("Чекаоница");
	protected final Container stolice   = box("Салон");
	protected final Container main      = column(cekaonica, stolice);
	protected final Operation berber    = init().name("Бербер %d").color(ROSE).text("Спава").container(stolice).update(this::azuriraj);
	protected final Operation musterija = duration("1±1").name("Мушт. %d").color(AZURE).text("Чека").container(cekaonica).update(this::azuriraj);
	protected final Operation sisanjeB  = duration("7").text("Шиша").update(this::azuriraj);
	protected final Operation sisanjeM  = duration("7").text("Шиша се").container(stolice).colorAfter(CHARTREUSE).textAfter("Ошишао се").update(this::azuriraj);

	protected void sisa() {
		sisanjeB.performUninterruptibly();
	}

	protected void sisaSe() {
		sisanjeM.performUninterruptibly();
	}

	protected void azuriraj(Item item) {
		long brB1 = 0;
		long brB2 = 0;
		for (Berber t : stolice.getItems(Berber.class)) {
			if (sisanjeB.getTextBefore().equals(t.getText())) {
				brB1++;
			} else {
				brB2++;
			}
		}
		long brM1 = stolice.stream(Musterija.class).count();
		long brM2 = cekaonica.stream(Musterija.class).count();
		cekaonica.setText(String.format("%d", brM2));
		stolice.setText(String.format("%d : %d", brB1, brM1));
		long razlika = brB1 - brM1;
		if (brB2 > 0 && brM2 > 0) {
			cekaonica.setColor(MAROON);
		} else {
			cekaonica.setColor(OLIVE);
		}
		if (razlika == 0) {
			stolice.setColor(ARMY);
		} else {
			stolice.setColor(MAROON);
		}
	}

	@Override
	protected void initialize() {
		azuriraj(null);
	}

	public static void main(String[] arguments) {
		launch("Успавани бербери");
	}
}