process_scheduling/process_scheduling.py at master · urmilshroff/process_scheduling · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
import numpy as np

class Process(object):
    def __init__(self,p_num):
        self.pid=p_num #process id of each process

        while True:
            try:
                self.bt=int(input("Enter Burst Time of process {}:\n".format(chr(self.pid+65)))) #chr+65 converts it to letter
                self.at=int(input("Enter Arrival Time of process {}:\n".format(chr(self.pid+65))))
                self.pr=int(input("Enter Priority of process {}:\n".format(chr(self.pid+65))))
                break

            except ValueError:
                print("Please enter a valid integer!\n")

    def get_pid(self): #getter functions
        return self.pid

    def get_bt(self):
        return self.bt

    def get_at(self):
        return self.at

    def get_pr(self):
        return self.pr


def process_arrived(tot_bt,at): #to check if the Process has actually arrived yet (for SJF)
    if tot_bt>=at:
        return True

    else:
        return False


def sort(sorted_processes): #to sort Process objects for SJF
    tot_bt=0

    for i in range(sorted_processes.size): #bubble sort
        for j in range(sorted_processes.size-1):

            if sorted_processes[j].get_bt() > sorted_processes[j+1].get_bt():
                tot_bt=tot_bt+sorted_processes[j+1].get_bt() #hypothetical test

                if process_arrived(tot_bt,sorted_processes[j+1].get_at()):
                    temp_obj=sorted_processes[j]
                    sorted_processes[j]=sorted_processes[j+1]
                    sorted_processes[j+1]=temp_obj

                else:
                    tot_bt=tot_bt-sorted_processes[j+1].get_bt() #revert

    return sorted_processes


def sjf(processes):
    sorted_processes=sort(processes)
    # wt,tot_wt,tot_bt,tat=0,0,0,0
    # print()
    #
    # for i in range(sorted_processes.size):
    #
    #     if process_arrived(tot_bt,sorted_processes[i].get_at()): #if the Process has arrived
    #         tot_bt=tot_bt+sorted_processes[i].get_bt()
    #         wt=wt-sorted_processes[i].get_at()
    #         tot_wt+=wt
    #         print("Waiting Time for Process {} is {}ms".format(chr(sorted_processes[i].get_pid()+65),wt))
    #         wt+=sorted_processes[i].get_bt()+sorted_processes[i].get_at()
    #
    #     else: #Process with highest priority must be executed next
    #
    #
    # print("\nAverage Waiting Time is {}ms\n".format(tot_wt/len(sorted_processes)))

    for i in range(sorted_processes.size): #prints new sorted array
        print("Process {} burst time is {}".format(chr(processes[i].get_pid()+65),processes[i].get_bt()))
    print()

def fcfs(processes):
    wt,tot_wt,tat=0,0,0
    print()

    for i in range(processes.size):
        wt=wt-processes[i].get_at()
        tot_wt+=wt
        print("Waiting Time for Process {} is {}ms".format(chr(processes[i].get_pid()+65),wt))
        wt+=processes[i].get_bt()+processes[i].get_at()

    print("\nAverage Waiting Time is {}ms\n".format(tot_wt/len(processes)))


def srtf(processes): #not coded yet
    pass


def roro(processes): #not coded yet
    pass


def prio(processes): #not coded yet
    pass


while True:
    try:
        processes=np.empty(int(input("Enter number of processes:\n")),object)
        break

    except ValueError: #handles bad input
        print("Please enter a valid integer!\n")

for p_num in range(processes.size):
    processes[p_num]=Process(p_num) #each Process object goes inside processes array

while True:
    try:
        choice=int(input("Which scheduling algorithm do you want to use?\n1. FCFS\n2. SJF\n3. SRTF \n4. Round Robin\n5. Priority\n*. Exit\n"))

        if choice==1:
            fcfs(processes)

        elif choice==2:
            sjf(processes)

        elif choice==3:
            srtf(processes)

        elif choice==4:
            roro(processes)

        elif choice==5:
            prio(processes)

        else:
            print("Peace out!\n")
            break

    except ValueError:
        print("Please enter a valid integer!\n")