-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmlfq_cpp.cpp
83 lines (68 loc) · 2.32 KB
/
mlfq_cpp.cpp
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
#include <iostream>
#include <vector>
using namespace std;
struct Process {
int process_id;
int burst_time;
int priority;
};
void enqueue(vector<Process>& queue, Process process) {
queue.push_back(process);
}
Process dequeue(vector<Process>& queue) {
Process front = queue.front();
queue.erase(queue.begin());
return front;
}
void displayQueue(const vector<Process>& queue, const string& queueName) {
cout << queueName << " Queue: ";
for (const auto& process : queue) {
cout << "[P" << process.process_id << " (Burst: " << process.burst_time << ", Priority: " << process.priority << ")] ";
}
cout << endl;
}
void multilevelFeedbackQueueScheduling(vector<Process>& processes) {
vector<Process> queues[3];
int time_quantum = 2;
for (int queue_index = 0; queue_index < 3; time_quantum *= 2, queue_index++) {
int current_time = 0;
int processed_processes = 0;
while (processed_processes < processes.size()) {
for (auto& process : processes) {
if (process.burst_time > 0 && process.burst_time <= time_quantum) {
process.burst_time = 0;
enqueue(queues[queue_index], process);
processed_processes++;
current_time += process.burst_time;
} else if (process.burst_time > time_quantum) {
process.burst_time -= time_quantum;
current_time += time_quantum;
}
}
displayQueue(queues[queue_index], "Current");
// Move processes to the next queue
for (auto& process : queues[queue_index]) {
if (process.burst_time > 0) {
enqueue(queues[queue_index + 1], process);
}
}
displayQueue(queues[queue_index + 1], "Next");
}
}
}
int main() {
vector<Process> processes = {
{1, 10, 3},
{2, 6, 5},
{3, 8, 2},
{4, 9, 1},
{5, 7, 4}
};
cout << "Initial Processes:" << endl;
for (const auto& process : processes) {
cout << "[P" << process.process_id << " (Burst: " << process.burst_time << ", Priority: " << process.priority << ")] ";
}
cout << "\n\n";
multilevelFeedbackQueueScheduling(processes);
return 0;
}