diff options
Diffstat (limited to 'yage/util')
-rw-r--r-- | yage/util/active.cpp | 37 | ||||
-rw-r--r-- | yage/util/active.h | 29 |
2 files changed, 65 insertions, 1 deletions
diff --git a/yage/util/active.cpp b/yage/util/active.cpp new file mode 100644 index 00000000..13e7fc38 --- /dev/null +++ b/yage/util/active.cpp @@ -0,0 +1,37 @@ +#include "active.h" + +namespace yage +{ + +Active::Active() : running_(true) {} + +Active::~Active() +{ + send([this] { running_ = false; }); + thread_.join(); +} + +std::unique_ptr<Active> Active::create() +{ + std::unique_ptr<Active> result(new Active); + + result->thread_ = std::thread(&Active::run, result.get()); + + return result; +} + +void Active::send(Callback message) +{ + queue_.push(message); +} + +void Active::run() +{ + Callback fn; + while (running_) { + queue_.pop(fn); + fn(); + } +} + +} // namespace yage diff --git a/yage/util/active.h b/yage/util/active.h index 877ab75e..ca8d30ad 100644 --- a/yage/util/active.h +++ b/yage/util/active.h @@ -1,11 +1,38 @@ #ifndef YAGE_UTIL_ACTIVE_H #define YAGE_UTIL_ACTIVE_H +#include "syncqueue.h" + +#include <functional> +#include <memory> +#include <thread> + +namespace yage +{ + class Active { public: + typedef std::function<void()> Callback; + + Active(const Active &) = delete; + Active &operator=(const Active &) = delete; + + ~Active(); + + static std::unique_ptr<Active> create(); + + void send(Callback message); + +private: Active(); - virtual ~Active(); + void run(); + + bool running_; + SyncQueue<Callback> queue_; + std::thread thread_; }; +} // namespace yage + #endif |