package mk.ukim.finki.os.synchronization.exam14.march.aloh3;

import java.util.Date;
import java.util.HashSet;
import java.util.concurrent.Semaphore;

import mk.ukim.finki.os.synchronization.ProblemExecution;
import mk.ukim.finki.os.synchronization.TemplateThread;

public class AluminiumHydroxide {

	static Semaphore o;
	static Semaphore h;
	static Semaphore al;

	static Semaphore ohHere;
	static Semaphore oHere;

	static Semaphore ohReady;
	static Semaphore ready;
	static Semaphore done;
	static Semaphore next;

	public static void init() {
		o = new Semaphore(3);
		h = new Semaphore(3);
		al = new Semaphore(1);

		oHere = new Semaphore(0);
		ohHere = new Semaphore(0);

		ohReady = new Semaphore(0);
		ready = new Semaphore(0);

		done = new Semaphore(0);
		next = new Semaphore(0);

	}

	public static class Hydrogen extends TemplateThread {

		public Hydrogen(int numRuns) {
			super(numRuns);
		}

		@Override
		public void execute() throws InterruptedException {
			h.acquire();
			oHere.acquire();
			ohReady.release();
			state.bondOH();
			ohHere.release();
			ready.acquire();
			state.bondAlOH3();
			done.release();
			next.acquire();
			h.release();
		}

	}

	public static class Oxygen extends TemplateThread {

		public Oxygen(int numRuns) {
			super(numRuns);
		}

		@Override
		public void execute() throws InterruptedException {
			o.acquire();
			oHere.release();
			ohReady.acquire();
			state.bondOH();
			ohHere.release();
			ready.acquire();
			state.bondAlOH3();
			done.release();
			next.acquire();
			o.release();
		}

	}

	public static class Aluminium extends TemplateThread {

		public Aluminium(int numRuns) {
			super(numRuns);
		}

		@Override
		public void execute() throws InterruptedException {
			al.acquire();
			ohHere.acquire(6);
			ready.release(6);
			state.bondAlOH3();
			done.acquire(6);
			next.release(6);
			state.validate();
			al.release();
		}

	}

	static AluminiumHydroxideState state = new AluminiumHydroxideState();

	public static void main(String[] args) {
		for (int i = 0; i < 10; i++) {
			run();
		}
	}

	public static void run() {
		try {
			int numRuns = 1;
			int numScenarios = 300;

			HashSet<Thread> threads = new HashSet<Thread>();

			for (int i = 0; i < numScenarios; i++) {
				Oxygen o = new Oxygen(numRuns);
				Hydrogen h = new Hydrogen(numRuns);
				threads.add(o);
				if (i % 3 == 0) {
					Aluminium al = new Aluminium(numRuns);
					threads.add(al);
				}
				threads.add(h);
			}

			init();

			ProblemExecution.start(threads, state);
			System.out.println(new Date().getTime());
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}

}