SushiBar

package mk.ukim.finki.os.synchronization.exam15.march.sushibar;

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

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

public class SushiBarSolution {
 public static Semaphore vlez=new Semaphore(6);
 public static Semaphore cekaj=new Semaphore(0);
 public static int lugje=0;



    public static void init() {
    }

    public static class Customer extends TemplateThread {

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

        @Override
        public void execute() throws InterruptedException {
        vlez.acquire();
        state.customerSeat();
        synchronized (state)
        {
            lugje++;
            if(lugje==6)
            {
                state.callWaiter();
                cekaj.release(6);
            }
        }
        cekaj.acquire();
        state.customerEat();
        synchronized(state)
        {
            lugje--;
            if(lugje==0)
            {
                state.eatingDone();
                vlez.release(6);
            }
        }



        }
    }

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

    static SushiBarState state = new SushiBarState();

    public static void run() {
        try {
            int numRuns = 1;
            int numIterations = 1200;

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

            for (int i = 0; i < numIterations; i++) {
                Customer c = new Customer(numRuns);
                threads.add(c);
            }

            init();

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

}