ОС - Транспорт на криминалци

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

package ispiti.criminalTransport;

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

class Locks{
    static int numCriminals = 0;
    static int numPoliceman = 0;
    static Semaphore lock;
    static Semaphore criminalEnter;
    static Semaphore policemanEnter;
    static Semaphore doneEntering;
    static Semaphore canExit;
    static Semaphore exitDone;

}
class Policeman extends Thread{

    public void execute() throws InterruptedException {
        Locks.lock.acquire();
        Locks.numPoliceman++;
        boolean controller = false;

        if(Locks.numPoliceman == 2 && Locks.numCriminals>=2){
            controller = true;
            Locks.criminalEnter.release(2);
            Locks.policemanEnter.release(2);
            Locks.numCriminals-=2;
            Locks.numPoliceman-=2;
        }else if(Locks.numPoliceman==4){
            controller = true;
            Locks.policemanEnter.release(4);
            Locks.numPoliceman-=4;
        }else{
            Locks.lock.release();
        }

        Locks.policemanEnter.acquire();
        System.out.println("Policeman enters in the car");
        Locks.doneEntering.release();

        if(controller){
            Locks.doneEntering.acquire(4);
            System.out.println("Policeman says start driving.");
            Thread.sleep(100);
            System.out.println("Policeman says arrived.");
            Locks.canExit.release(3);
            System.out.println("Policeman exits from the car");
            Locks.exitDone.acquire(3);
            System.out.println("Gotovo");
            Locks.lock.release();
        }else{
            Thread.sleep(100);
            Locks.canExit.acquire();
            System.out.println("Policeman exits from the car");
            Locks.exitDone.release();
        }
    }

    @Override
    public void run() {
        try {
            execute();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

class Criminal extends Thread {

    public void execute() throws InterruptedException {
        Locks.lock.acquire();
        Locks.numCriminals++;
        Locks.lock.release();

        Locks.criminalEnter.acquire();
        System.out.println("Criminal enters in the car");
        Locks.doneEntering.release();

        //sega se vozat
        Thread.sleep(100);
        Locks.canExit.acquire();
        System.out.println("Criminal exits from the car");
        Locks.exitDone.release();

    }

    @Override
    public void run() {
        try {
            execute();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class CriminalTransport {

    public static void init(){
        Locks.lock = new Semaphore(1);
        Locks.policemanEnter = new Semaphore(0);
        Locks.criminalEnter = new Semaphore(0);
        Locks.doneEntering = new Semaphore(0);
        Locks.canExit = new Semaphore(0);
        Locks.exitDone = new Semaphore(0);
    }


    public static void main(String[] args) throws InterruptedException {
        HashSet<Thread> threads = new HashSet<Thread>();
        for (int i = 0; i < 60; i++) {
            Policeman red = new Policeman();
            threads.add(red);
            Criminal green = new Criminal();
            threads.add(green);
        }
        init();
        // run all threads in background
        for(Thread t:threads){
            t.start();
        }
        // after all of them are started, wait each of them to finish for maximum 1_000 ms
        for(Thread t:threads){
            t.join();
        }
        // for each thread, terminate it if it is not finished
        System.out.println("Uspeshno!!!");
    }

}