X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=schedule.h;h=fb4d082adc2dbe220baf49d8347fc70fe6c0d560;hb=381e2769f94f7e41c1c90d3ab633a37136fa24b0;hp=64531b5e94eb5023887b6779bcd5acb132bc82df;hpb=517d8ce6cc880bb523ee55005afdcad1ec551e64;p=model-checker.git diff --git a/schedule.h b/schedule.h index 64531b5..fb4d082 100644 --- a/schedule.h +++ b/schedule.h @@ -1,18 +1,39 @@ +/** @file schedule.h + * @brief Thread scheduler. + */ + #ifndef __SCHEDULE_H__ #define __SCHEDULE_H__ -#include +#include +#include "mymemory.h" -#include "threads.h" -#include "model.h" +/* Forward declaration */ +class Thread; +/** @brief The Scheduler class performs the mechanics of Thread execution + * scheduling. */ class Scheduler { public: + Scheduler(); void add_thread(Thread *t); - Thread * next_thread(void); - Thread * get_current_thread(void); + void remove_thread(Thread *t); + void sleep(Thread *t); + void wake(Thread *t); + Thread * next_thread(Thread *t); + Thread * get_current_thread() const; + void print() const; + bool * get_enabled() { return is_enabled; }; + + SNAPSHOTALLOC private: - std::queue queue; + /** The list of available Threads that are not currently running */ + bool * is_enabled; + int enabled_len; + int curr_thread_index; + void set_enabled(Thread *t, bool enabled_status); + + /** The currently-running Thread */ Thread *current; };