-#include "libthreads.h"
+#include "threads_internal.h"
#include "schedule.h"
#include "common.h"
#include "model.h"
-void DefaultScheduler::add_thread(struct thread *t)
+void Scheduler::add_thread(Thread *t)
{
- DEBUG("thread %d\n", t->id);
- queue.push_back(t);
+ DEBUG("thread %d\n", t->get_id());
+ queue.push(t);
}
-struct thread *DefaultScheduler::next_thread(void)
+Thread *Scheduler::next_thread(void)
{
if (queue.empty())
return NULL;
current = queue.front();
- queue.pop_front();
+ queue.pop();
return current;
}
-struct thread *DefaultScheduler::get_current_thread(void)
+Thread *Scheduler::get_current_thread(void)
{
return current;
}