X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=schedule.cc;h=67b40ec88a809d5c2bff10e07787481a7d934566;hb=d279e84ed265af079ea035d5dff49183def2c144;hp=13b640cd8e832b2cca826e5a4b68d66143bb854c;hpb=94c12b28e9afeed050f40c3d2d625fa0e22f0387;p=model-checker.git diff --git a/schedule.cc b/schedule.cc index 13b640c..67b40ec 100644 --- a/schedule.cc +++ b/schedule.cc @@ -9,24 +9,40 @@ void Scheduler::add_thread(Thread *t) readyList.push_back(t); } -Thread *Scheduler::next_thread(void) +Thread * Scheduler::next_thread(void) { Thread *t = model->schedule_next_thread(); if (t != NULL) { + current = t; readyList.remove(t); - return t; + } else if (readyList.empty()) { + t = NULL; + } else { + t = readyList.front(); + current = t; + readyList.pop_front(); } - if (readyList.empty()) - return NULL; - current = readyList.front(); - readyList.pop_front(); + print(); - return current; + return t; } -Thread *Scheduler::get_current_thread(void) +Thread * Scheduler::get_current_thread(void) { return current; } + +void Scheduler::print() +{ + if (current) + printf("Current thread: %d\n", current->get_id()); + else + printf("No current thread\n"); + printf("Num. threads in ready list: %ld\n", readyList.size()); + + std::list::iterator it; + for (it = readyList.begin(); it != readyList.end(); it++) + printf("In ready list: thread %d\n", (*it)->get_id()); +}