Концерт2

//reshenie na:
//https://github.com/finki-mk/OS/tree/master/synchronization/src/main/java/mk/ukim/finki/os/synchronization/exam17/k1/g3
package ispiti.concert;


import ispiti.ProblemExecution;
import ispiti.TemplateThread;

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

public class Concert2 {

    static Semaphore performerHere;
    static Semaphore perfomer;
    static Semaphore baritoni;
    static Semaphore tenori;
    static Semaphore tenorHere;
    static Semaphore readyToForm;
    static Semaphore groups;
    static Semaphore formingDone;
    static Semaphore canPerform;
    static Semaphore donePerforming;

    public static void init() {
        perfomer = new Semaphore(1);
        performerHere = new Semaphore(0);
        baritoni = new Semaphore(3);
        tenori = new Semaphore(3);
        tenorHere = new Semaphore(0);
        readyToForm = new Semaphore(0);
        groups = new Semaphore(0);
        formingDone = new Semaphore(0);
        canPerform = new Semaphore(0);
        donePerforming = new Semaphore(0);

    }

    public static class Performer extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
            perfomer.acquire();
            state.performerHere();
            performerHere.release(6);

            groups.acquire(3);
            canPerform.release(6);
            state.perform();
            donePerforming.acquire(6);

            state.vote();
            perfomer.release();
            tenori.release(3);
            baritoni.release(3);
        }

    }

    public static class Baritone extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
            baritoni.acquire(); //maks 3 baritoni smeat
            performerHere.acquire(); //mora prvo da se osigurame deka navstina dosol performer

            tenorHere.acquire(); //cekame da vidime dali stignal tenor
            readyToForm.release(); //ako stignal znaci moze da se formira grupa
            state.formBackingVocals(); //se formira grupata
            formingDone.acquire(); //dobivame poraki od tenorite, dali se formirale grupite, i taka mu kazuvame na izveduvacot

            groups.release();
            canPerform.acquire();
            state.perform();
            donePerforming.release();

        }

    }

    public static class Tenor extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
            tenori.acquire();
            performerHere.acquire();

            tenorHere.release();
            readyToForm.acquire();
            state.formBackingVocals();
            formingDone.release();

            canPerform.acquire();
            state.perform();
            donePerforming.release();
        }

    }

    static Concert2State state = new Concert2State();

    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();
        }
    }

}