Asynchronous logging added

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