COMP2240-Assignment1/SRT.java

import java.util.LinkedList;

/**
 * Shortest Remaining Time
 */
public class SRT {

    private int timeStep = 0;
    private int disp;
    private int timeLastChecked = -1;

    private static LinkedList<Process> processListFromFile;   //Original List of processes from the the file
    private LinkedList<Process> waitingQueue = new LinkedList<>();  //Processes officially added to the waiting queue.
    private LinkedList<Process> newProcesses = new LinkedList<>();  //Processes that have arrived after each time point.
    //Constructors

    public SRT(int dispInput, LinkedList<Process> processListInput)
    {
        disp = dispInput;
        processListFromFile = processListInput;
    }


    private void checkForArrivals()
    {
        for(int i = 0; i< processListFromFile.size(); i++)
        {
            if((processListFromFile.get(i).getArrive()<=timeStep) && (processListFromFile.get(i).getArrive() > timeLastChecked))
            {
                newProcesses.add(processListFromFile.get(i));
            }
        }

        timeLastChecked = timeStep;

        //do any tie breaking by sorting the new processes based on name
        boolean swap = false;
        do
        {
            swap = false;
            for(int i = 0; i< newProcesses.size()-1; i++)
            {          
                if(Integer.parseInt(newProcesses.get(i).getId().substring(1))>Integer.parseInt(newProcesses.get(i+1).getId().substring(1)))
                {
                    Process temp = newProcesses.get(i);
                    newProcesses.remove(i);
                    newProcesses.add(i+1, temp);
                    swap = true;
                }
            }
        }while(swap);

        //Move the newly arrived (and organised) processes to the queue.
        for(int i =0; i < newProcesses.size(); i++)
        {
            waitingQueue.add(newProcesses.get(i));
        }
        
        newProcesses.clear();
    }

    public void runDispatch()
    {
        System.out.println("SRT:");
        int processesFinished = 0;
        boolean startNew = true;
        int shortestProcess = -1;
        int lastRunProcess = -1;
        //timeStep++;
        
        do
         {
            checkForArrivals();
            shortestProcess = findShortestProcess();
             
            if(waitingQueue.size()>0)
            {
                if(lastRunProcess!=shortestProcess)
                {
                    System.out.println("T"+timeStep+": "+waitingQueue.get(shortestProcess).getId());
                    timeStep = timeStep+disp;
                }

                runProcessTick(waitingQueue.get(shortestProcess));

                if(waitingQueue.get(shortestProcess).isDone())
                {
                    waitingQueue.remove(shortestProcess);
                    processesFinished++;
                }
                lastRunProcess = shortestProcess;
            }
            
         }while(processesFinished!=processListFromFile.size());      
    }

    private int findShortestProcess()
    {
        int listPos = 0;
        int remaining = waitingQueue.get(0).getRemainingTime();

        for(int i = 1; i<waitingQueue.size(); i++)
        {
            if(waitingQueue.get(i).getRemainingTime()<remaining)
            {
                listPos = i;
                remaining = waitingQueue.get(i).getRemainingTime();
            }
        }

        return listPos;
    }

    private void runProcessTick(Process input)
    {   
        input.saveStartTime(timeStep);
        
        timeStep++;

        input.runForOneTick();

        if(input.isDone())
        {
            input.saveEndTime(timeStep);
            input.saveTurnTime();
            input.saveWaitTime();
        }       
    }    

    public void printResults()
    {
        for (int i = 0; i < processListFromFile.size(); i++)
        {
            //System.out.println("T"+processListFromFile.get(i).getStartTime()+": "+processListFromFile.get(i).getId());
        }
        
        System.out.println("\nProcess \tTurnaround Time \tWaiting Time");
        for (int i = 0; i < processListFromFile.size(); i++)
        {
            System.out.print(processListFromFile.get(i).getId()+"\t\t");
            System.out.print(processListFromFile.get(i).getTurnTime()+"\t\t\t");
            System.out.print(processListFromFile.get(i).getWaitTime()+"\n");
        }
    }
}