X-Git-Url: http://plrg.eecs.uci.edu/git/?p=c11tester.git;a=blobdiff_plain;f=schedule.h;h=fb4d082adc2dbe220baf49d8347fc70fe6c0d560;hp=83416008eb01f2e0dba5e3886e49fdda52e68846;hb=70525635cea4c0622d30571c7028c1c293950bb5;hpb=3e3ba08b7f8483430946ac7db0cc3bdbaa6f8a90 diff --git a/schedule.h b/schedule.h index 83416008..fb4d082a 100644 --- a/schedule.h +++ b/schedule.h @@ -1,19 +1,40 @@ +/** @file schedule.h + * @brief Thread scheduler. + */ + #ifndef __SCHEDULE_H__ #define __SCHEDULE_H__ -#include +#include +#include "mymemory.h" -#include "libthreads.h" -#include "model.h" +/* Forward declaration */ +class Thread; +/** @brief The Scheduler class performs the mechanics of Thread execution + * scheduling. */ class Scheduler { public: - void add_thread(struct thread *t); - struct thread * next_thread(void); - struct thread * get_current_thread(void); + Scheduler(); + void add_thread(Thread *t); + 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; - struct thread *current; + /** 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; }; #endif /* __SCHEDULE_H__ */