Sarting synch.rs implementation

This commit is contained in:
Rémi Rativel 2023-03-08 15:45:35 +01:00
parent 8889d43f9d
commit cf65688566
2 changed files with 45 additions and 1 deletions

View File

@ -4,3 +4,4 @@ pub mod scheduler;
pub mod mgerror; pub mod mgerror;
pub mod system; pub mod system;
mod ucontext; mod ucontext;
mod synch;

43
src/kernel/synch.rs Normal file
View File

@ -0,0 +1,43 @@
use crate::utility::list::List;
use crate::kernel::thread::Thread;
use std::rc::Rc;
use crate::simulator::interrupt::InterruptStatus::InterruptOff;
use crate::simulator::machine::Machine;
pub struct Semaphore{
counter:i32,
waiting_queue:List<Rc<Thread>>
}
impl Semaphore{
pub fn p(&mut self, current_thread:Rc<Thread>, machine: &mut Machine){
let old_status = machine.interrupt.set_status(InterruptOff);
self.counter-=1;
if self.counter < 0 {
self.waiting_queue.push(Rc::clone(&current_thread));
current_thread.sleep();
}
machine.interrupt.set_status(old_status);
}
pub fn v(&mut self, current_thread:Rc<Thread>, machine: &mut Machine){
let old_status = machine.interrupt.set_status(InterruptOff);
self.counter-=1;
if self.waiting_queue.peek == None {
self.waiting_queue.push(Rc::clone(&current_thread));
current_thread.sleep();
}
machine.interrupt.set_status(old_status);
}
}
pub struct Lock{
}
pub struct Condition{
}