apio/Luna
1
1
Fork 0
Code Issues Pull Requests Actions Projects Releases 8 Wiki Activity

Check for runnable threads

Browse Source
This commit is contained in:
apio 2022-12-07 15:17:20 +01:00 committed by Gitea
parent 57517252d8
commit 70497c37fb
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
kernel/src/thread/Scheduler.cpp
View File

@ -88,22 +88,29 @@ namespace Scheduler
Thread* old = g_current; Thread* old = g_current;
if (old->is_idle()) if (old->is_idle())
{ {
auto maybe_first = g_threads.last(); auto maybe_last = g_threads.last();
if (maybe_first.has_error()) // No threads!! if (maybe_last.has_error()) // No threads!!
return &g_idle; return &g_idle;
g_current = old = maybe_first.value(); g_current = old = maybe_last.value();
} }
bool has_found_thread = false;
do { do {
auto maybe_next = g_threads.next(g_current); auto maybe_next = g_threads.next(g_current);
if (maybe_next.has_error()) g_current = g_threads.first().value(); if (maybe_next.has_error()) g_current = g_threads.first().value();
else else
g_current = maybe_next.value(); g_current = maybe_next.value();
if (true) // FIXME: Check if the current task is runnable. if (g_current->state == ThreadState::Runnable)
{
has_found_thread = true;
break; break;
}
} while (g_current != old); } while (g_current != old);
if (!has_found_thread) g_current = &g_idle;
return g_current; return g_current;
} }