schedule.cc

   1 #include "libthreads.h"
   2 #include "schedule.h"
   3 #include "common.h"
   4 #include "model.h"
   5
   6 void DefaultScheduler::add_thread(struct thread *t)
   7 {
   8         DEBUG("thread %d\n", t->id);
   9         queue.push(t);
  10 }
  11
  12 struct thread *DefaultScheduler::next_thread(void)
  13 {
  14         if (queue.empty())
  15                 return NULL;
  16
  17         current = queue.front();
  18         queue.pop();
  19
  20         return current;
  21 }
  22
  23 struct thread *DefaultScheduler::get_current_thread(void)
  24 {
  25         return current;
  26 }