schedule.py

import random
import queue    #For FIFO queue
import heapq    #For priority queues

import FIFO
#Global time variable
time = 0

class Process:
    def __init__(self, process_id, cpu_burst_time, start_time = 0, priority = None):
        self.process_id = process_id
        self.cpu_burst_time = cpu_burst_time
        self.wait_time = 0
        self.priority = priority
        self.start_time = start_time

        self.init_wait_time = 0
        self.total_wait_time = 0
        self.process_time = 0
        self.turnaround_time = 0

    def wait(self):
        self.wait_time += 1

    def set_init_wait_time(self):
        self.init_wait_time = time - self.start_time

    def add_to_wait_time(self, delta_t):
        pass

    # Returns true if a process is complete
    def inc_process_time(self):
        self.process_time += 1
        if self.process_time >= self.cpu_burst_time:
            return True
        return False

    def store_turnaround_time(self):
        self.turnaround_time = time - self.start_time

    #Returns a tuple for process:
    # (turnaround time, initial wait time, total wait time)
    def get_stats(self):
        return self.turnaround_time, self.init_wait_time, self.total_wait_time


    def __repr__(self):
        return self.process_id + " " + self.cpu_burst_time

class CPU:
    def __init__(self, name):
        self.name = name
        self.current_running_process = None

    def add_process(self, process):
        if( self.current_running_process is None ):
            self.current_running_process = process
            return True
        else:
            return False

    def has_running_process(self):
        return (process is not None)

    def release_process(self):
        temp_process = self.current_running_process
        self.current_running_process = None
        return temp_process

    def __repr__(self):
        return self.name


def schedule_process(next_process, cpu_list):
    global time #make time global throughout
    process_running = False
    while(process_running is False):
        for cpu in cpu_list:
            if(cpu.add_process(next_process) is True):
                process_running = True
                break
            #Increment time upon trying to add a process
            time += 1
            next_process.wait() #If could not run, then increment waiting time


def FCFS_scheduler(process_queue, cpu_list):
    while(process_queue.empty() is False):
        next_process = process_queue.get()
        schedule_process(next_process, cpu_list)

def priority_scheduler(process_queue, cpu_list):
    priority_queue = []
    for process in process_queue:
        heappush(priority_queue, process)

num_cpus = 4
num_processes = 20
tcs = 15
cpus = list()
#Create the n CPUs
for i in range(0, num_cpus):
    #Initialize CPUs with sequential name
    cpu_name = chr(i + 65)
    cpus.append(CPU(cpu_name) )

process_queue = queue.Queue(num_processes)
process_list = () #Process list for continuity while using different queues
#Create the processes
for i in range(0, num_processes):
    #Initialize processes with sequential pid and random cpu burst
    cpu_burst = random.randrange(50, 400)
    process = Process(i, cpu_burst)
    process_queue.put(process, False)
    process_list.append(process)

FIFO.FIFO_scheduler(process_queue, cpus, tcs)