X-Git-Url: http://plrg.eecs.uci.edu/git/?p=cdsspec-compiler.git;a=blobdiff_plain;f=schedule.h;h=fb4d082adc2dbe220baf49d8347fc70fe6c0d560;hp=ac69fa1163bfdfb3d8aff5a1f4ad249cdecb54e0;hb=cd61f25e9775d3807c09f0606a69440604ef1821;hpb=01237c41090e450db348ef0045a3d3cfd23cd041 diff --git a/schedule.h b/schedule.h index ac69fa1..fb4d082 100644 --- a/schedule.h +++ b/schedule.h @@ -1,9 +1,40 @@ +/** @file schedule.h + * @brief Thread scheduler. + */ + #ifndef __SCHEDULE_H__ #define __SCHEDULE_H__ -#include "libthreads.h" +#include +#include "mymemory.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); + 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: + /** 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); -void schedule_add_thread(struct thread *t); -struct thread *schedule_choose_next(void); + /** The currently-running Thread */ + Thread *current; +}; #endif /* __SCHEDULE_H__ */