cpu-schscuhedling-rs/src/main.rs

use std::io;
fn main() {
    // Take user input
    let proc_num: i32;
    let mut processes: Vec<Process> = vec![];

    let mut input: String = String::from("");
    println!("Enter process number!");
    _ = io::stdin().read_line(&mut input);
    proc_num = input.trim().parse().expect("NOT NUMBER");

    let mut num: i32 = 0;
    while num < proc_num {
        println!("Enter arrival for process");
        let mut temp_arrival = String::new();
        _ = io::stdin().read_line(&mut temp_arrival);
        let temp_arrival: i32 = temp_arrival.trim().parse().expect("AAAAAA");

        println!("Enter burst for process");
        let mut temp_burst = String::new();
        _ = io::stdin().read_line(&mut temp_burst);
        let temp_burst: i32 = temp_burst.trim().parse().expect("AAAAAA");

        let temp_proc = Process {
            arrival: temp_arrival,
            burst: temp_burst,
            turnaround: 0,
            waiting: 0,
            remaining: temp_burst,
            completion_time: 0,
        };
        processes.push(temp_proc);
        num += 1;
    }
    println!("sorting!");
    let sorted = round_robin(processes, 2);
    // let sorted = round_robin(processes, vec![], 0, 2);
    println!("You've entered: ");
    for proc in sorted {
        println!("{:#?}", proc)
    }
}

#[derive(Debug, Copy, Clone)]
pub struct Process {
    arrival: i32,
    burst: i32,
    turnaround: i32,
    waiting: i32,
    remaining: i32,
    completion_time: i32,
}
impl Process {
    pub fn quan_zap(self, q: i32, current: i32) -> (i32, i32) {
        if q < 0 {
            println!("Why would you ever do this?");
            return (0, 0);
        }
        if self.remaining >= q {
            (self.remaining - q, current + q)
        } else {
            (0, current + self.remaining)
        }
    }
    pub fn calc_turn(self) -> i32 {
        self.completion_time - self.arrival
    }
    pub fn calc_wait(self) -> i32 {
        self.turnaround - self.burst
    }
    pub fn one_shot(mut self, current: i32) -> (Process, i32) {
        self.completion_time = current + self.remaining;
        self.remaining = 0;
        (self, self.completion_time)
    }
    pub fn robin_zap(self, q: i32) -> i32 {
        if self.remaining >= q {
            self.remaining - q
        } else {
            0
        }
    }
}

// pub fn srt(procs: Vec<Process>, q: i32) -> Vec<Process> {
// procs.sort_by(|a, b| a.arrival.cmp(&b.arrival));
//     let mut smallest = procs[0];
//     let mut current = 0;
//     let mut completed: Vec<Process> = vec![];
//     todo!()
// }

pub fn fifo(mut procs: Vec<Process>) -> Vec<Process> {
    procs.sort_by(|a, b| a.arrival.cmp(&b.arrival));
    let mut clock = procs[0].arrival;
    let mut completed: Vec<Process> = vec![];
    for proc in procs {
        if proc.arrival <= clock {
            let mut done_proc: Process;
            (done_proc, clock) = proc.one_shot(clock);
            done_proc.turnaround = done_proc.calc_turn();
            done_proc.waiting = done_proc.calc_wait();
            completed.push(done_proc);
        }
    }
    completed
}

pub fn sjf(mut procs: Vec<Process>, mut completed: Vec<Process>, mut clock: i32) -> Vec<Process> {
    procs.sort_unstable_by_key(|proc| (proc.burst, proc.arrival));

    if procs.is_empty() {
        completed
    } else {
        let mut i = 0;
        while i < procs.len() {
            if procs[i].arrival <= clock {
                let mut done_proc: Process;
                (done_proc, clock) = procs[i].one_shot(clock);
                done_proc.turnaround = done_proc.calc_turn();
                done_proc.waiting = done_proc.calc_wait();
                completed.push(done_proc);
                procs.remove(i);
                return sjf(procs, completed, clock);
            } else {
                i += 1
            }
        }
        sjf(procs, completed, clock + 1)
    }
}
pub fn round_robin(procs: Vec<Process>, q: i32) -> Vec<Process> {
    let mut buffer = procs.to_owned();
    buffer.sort_by(|a, b| a.arrival.cmp(&b.arrival));
    let mut current_time = 0;
    let mut in_cpu: Vec<Process> = vec![];
    let mut done: Vec<Process> = vec![];
    loop {
        let ready: Vec<&Process> = buffer
            .iter()
            .filter(|proc| proc.arrival <= current_time)
            .collect();
        buffer
            .to_owned()
            .retain(|&proc| proc.arrival > current_time);
        for proc in ready.to_owned() {
            in_cpu.insert(0, *proc);
        }
        // ready.iter().map(|proc| in_cpu.insert(0, **proc));
        match in_cpu.to_owned().first_mut() {
            Some(proc) => {
                (proc.remaining, current_time) = proc.quan_zap(q, current_time);
                if proc.remaining == 0 {
                    proc.completion_time = current_time;
                    proc.turnaround = proc.calc_turn();
                    proc.waiting = proc.calc_wait();
                    done.push(proc.to_owned());
                } else {
                    in_cpu.push(proc.to_owned())
                }
                in_cpu.remove(0);
            }
            None => current_time += 1,
        }

        if done.len() == procs.len() {
            break;
        }
    }
    done
}

// This code sucks!