Paul/tiny_os
1
0
Fork 0
mirror of https://github.com/panpaul/tiny_os synced 2024-09-20 09:45:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: kernel/scheduler: skip idle thread if there are any other threads available to run

Browse Source
This commit is contained in:
Paul Pan 2024-08-29 20:41:34 +08:00
parent 7b54abcc13
commit 9f4a804e30
1 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
kernel/src/scheduler.rs
View File

@ -2,7 +2,7 @@ use crate::objects::*;
use core::sync::atomic::AtomicPtr;
use log::{error, trace};
use spin::lazy::Lazy;
use tcb::SCHED_QUEUE_LINK_ID;
use tcb::{ThreadState, SCHED_QUEUE_LINK_ID};
use utils::{container_of_mut, linked_list::Link};
#[thread_local]
@ -38,10 +38,29 @@ impl Scheduler {
self.head.prepend(tcb);
}
pub fn add_next(&self, tcb: &TcbObject) {
self.head.append(tcb);
}
pub fn schedule(&self) {
let mut idle_found = false;
while let Some(next) = self.head.next_mut() {
if next.timetick() > 0 && next.schedulable() {
trace!("Scheduling thread {}", next.tid());
if next.state() == ThreadState::Idle {
debug_assert!(next.tid() == 0, "IDLE thread should have TID 0");
if !idle_found {
// we are meeting the idle thread for the first time, bypass it
idle_found = true;
} else {
// no other thread could be scheduled
trace!("[Scheduler] Scheduling IDLE thread");
next.refill_timetick();
next.activate();
}
} else if next.timetick() > 0 && next.schedulable() {
trace!("[Scheduler] Scheduling thread {}", next.tid());
idle_found = false;
next.activate();
} else if next.timetick() == 0 {
next.refill_timetick();