ос - Концерт

//reshenie na:
//https://github.com/finki-mk/OS/tree/master/synchronization/src/main/java/mk/ukim/finki/os/synchronization/exam17/k1/g2

package ispiti.concert;

import ispiti.ProblemExecution;
import ispiti.TemplateThread;

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

public class Concert {

    static Semaphore triGrupi;
    static Semaphore baritoni;
    static Semaphore tenori;
    static Semaphore izveduvac;
    static Semaphore ready;
    static Semaphore signalBacking;
    static Semaphore finished;
    static Semaphore finishedForming;

    static Semaphore tenorHere;
    static Semaphore baritonHere;

    static int numBaritons = 0;


    public static void init() {
        triGrupi = new Semaphore(0);
        tenorHere = new Semaphore(0);
        baritonHere = new Semaphore(0);
        baritoni = new Semaphore(3);
        tenori = new Semaphore(3);
        ready = new Semaphore(0);
        izveduvac = new Semaphore(1);
        signalBacking = new Semaphore(0);
        finished = new Semaphore(0);
        finishedForming = new Semaphore(0);

    }


    public static class Baritone extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
            baritoni.acquire(); //maks 3 baritoni moze da dojda
            numBaritons++; //fali samo lock za ova da se zashtiti
            boolean controller = false;
            if(numBaritons==3){ //posledniot bariton ke bide kontrolerot
                controller = true;
            }
            tenorHere.acquire(); //cekam da pristigne eden tenor za da formiram grupa
            //tuka vekje teoretski e formirana edna grupa
            ready.release(); //go izvestuvam tenorot deka grupata e formirana
            state.formBackingVocals();
            finishedForming.release(); //site izvestuvaat deka so formiranjeto zavrsile

            if(controller){
                finishedForming.acquire(6); //kontrolerot mora da se osigura deka site 6 backup vokali zavrsile
                triGrupi.release(3); //ako e taka, ke mu kaze na izveduvacot deka sega ima 3 grupi
            }

            signalBacking.acquire(); //sekoj backup vokal treba da dobie od izveduvacot signal deka moze da pocne so izveduvanje
            state.perform();
            finished.release(); //koga zavrsuvaat mu kazuvaat na izveduvacot deka zavrsile

        }

    }

    public static class Tenor extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
            tenori.acquire(); //maks 3 tenori
            tenorHere.release();
            ready.acquire(); //cekam odgovor deka moze da se formira grupata
            state.formBackingVocals();
            finishedForming.release(); //kazuva deka zavrsil so formiranje

            signalBacking.acquire();
            state.perform();
            finished.release();
        }

    }


    public static class Performer extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
            izveduvac.acquire();
            triGrupi.acquire(3);

            signalBacking.release(6); //site 6 treba da gi izvestime deka moze da pocne so perform
            state.perform();
            finished.acquire(6); //baram odgovor deka zavrsile so performing
            state.vote();

            //sega treba da se ostavi prostor za drug izveduvac so negovite 3 grupi
            numBaritons = 0;
            tenori.release(3);
            baritoni.release(3);

            izveduvac.release();

        }

    }

    static ConcertState state = new ConcertState();

    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++) {
                Tenor t = new Tenor(numRuns);
                Baritone b = new Baritone(numRuns);
                threads.add(t);
                if (i % 3 == 0) {
                    Performer p = new Performer(numRuns);
                    threads.add(p);
                }
                threads.add(b);
            }

            init();

            ProblemExecution.start(threads, state);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

}