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

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

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

public class CalciumNitride {
	public static Semaphore Ca;
	public static Semaphore n;
	public static Semaphore ntuka;
	public static Semaphore mozeBond;
	public static Semaphore lock;

	static int count;

    public static void init() {
    	Ca = new Semaphore(3);
    	n = new Semaphore(2);
    	ntuka = new Semaphore(0);
    	mozeBond = new Semaphore(0);
    	lock = new Semaphore(1);


    	count = 0 ;
    }

    public static class Calcium extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
        	Ca.acquire();
        	lock.acquire();
        	if(count == 2){
        		lock.release();
        		ntuka.acquire(2);
        		mozeBond.acquire(4);
        		state.bond();
        		state.validate();
        		count = 0;
        		Ca.release(3);
        		n.release(2);
        	}
        	else{
        		count++;
        		lock.release();
        		mozeBond.release();
        		state.bond();
        	}


        }
    }

    public static class Nitrogen extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
        	n.acquire();
        	ntuka.release();
        	mozeBond.release();
        	state.bond();
        }
    }
    static CalciumNitrideState state = new CalciumNitrideState();

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

    public static void run() {
        try {
            Scanner s = new Scanner(System.in);
            int numRuns = 1;
            int numIterations = 100;
            s.close();

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

            for (int i = 0; i < numIterations; i++) {
                Nitrogen n = new Nitrogen(numRuns);
                threads.add(n);
                Calcium ca = new Calcium(numRuns);
                threads.add(ca);
                ca = new Calcium(numRuns);
                threads.add(ca);
                n = new Nitrogen(numRuns);
                threads.add(n);
                ca = new Calcium(numRuns);
                threads.add(ca);
            }

            init();

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