1 files changed, 111 insertions, 0 deletions
diff --git a/src/core/Threading/Threading.cpp b/src/core/Threading/Threading.cpp
new file mode 100644
index 0000000000..e62d92dea8
--- /dev/null
+++ b/src/core/Threading/Threading.cpp
@@ -0,0 +1,111 @@
+/*
+ * Copyright (C) 2016+     AzerothCore <www.azerothcore.org>, released under GNU GPL v2 license: http://github.com/azerothcore/azerothcore-wotlk/LICENSE-GPL2
+ * Copyright (C) 2008-2016 TrinityCore <http://www.trinitycore.org/>
+ * Copyright (C) 2005-2009 MaNGOS <http://getmangos.com/>
+ */
+
+#include "Threading.h"
+#include "Errors.h"
+
+#include <chrono>
+#include <system_error>
+
+using namespace ACORE;
+
+Thread::Thread() : m_task(nullptr), m_iThreadId(), m_ThreadImp()
+{
+}
+
+Thread::Thread(Runnable* instance) : m_task(instance), m_ThreadImp(&Thread::ThreadTask, (void*)m_task)
+{
+    m_iThreadId = m_ThreadImp.get_id();
+
+    // register reference to m_task to prevent it deeltion until destructor
+    if (m_task)
+        m_task->incReference();
+}
+
+Thread::~Thread()
+{
+    // Wait();
+
+    // deleted runnable object (if no other references)
+    if (m_task)
+        m_task->decReference();
+}
+
+bool Thread::wait()
+{
+    if (m_iThreadId == std::thread::id() || !m_task)
+        return false;
+
+    bool res = true;
+
+    try
+    {
+        m_ThreadImp.join();
+    }
+    catch (std::system_error&)
+    {
+        res = false;
+    }
+
+    m_iThreadId = std::thread::id();
+
+    return res;
+}
+
+void Thread::destroy()
+{
+    if (m_iThreadId == std::thread::id() || !m_task)
+        return;
+
+    // FIXME: We need to make sure that all threads can be trusted to
+    // halt execution on their own as this is not an interrupt
+    m_ThreadImp.join();
+    m_iThreadId = std::thread::id();
+}
+
+void Thread::ThreadTask(void* param)
+{
+    Runnable* _task = (Runnable*)param;
+    _task->run();
+}
+
+std::thread::id Thread::currentId()
+{
+    return std::this_thread::get_id();
+}
+
+void Thread::setPriority(Priority priority)
+{
+#ifdef WIN32
+    std::thread::native_handle_type handle = m_ThreadImp.native_handle();
+#endif
+
+    bool _ok = true;
+
+    switch (priority)
+    {
+#ifdef WIN32
+        case Priority_Realtime: _ok = SetThreadPriority(handle, THREAD_PRIORITY_TIME_CRITICAL); break;
+        case Priority_Highest: _ok = SetThreadPriority(handle, THREAD_PRIORITY_HIGHEST);       break;
+        case Priority_High: _ok = SetThreadPriority(handle, THREAD_PRIORITY_ABOVE_NORMAL);  break;
+        case Priority_Normal: _ok = SetThreadPriority(handle, THREAD_PRIORITY_NORMAL);        break;
+        case Priority_Low: _ok = SetThreadPriority(handle, THREAD_PRIORITY_BELOW_NORMAL);  break;
+        case Priority_Lowest: _ok = SetThreadPriority(handle, THREAD_PRIORITY_LOWEST);        break;
+        case Priority_Idle: _ok = SetThreadPriority(handle, THREAD_PRIORITY_IDLE);          break;
+#endif
+        default:
+            break;
+    }
+
+
+    // remove this ASSERT in case you don't want to know is thread priority change was successful or not
+    ASSERT(_ok);
+}
+
+void Thread::Sleep(unsigned long msecs)
+{
+    std::this_thread::sleep_for(std::chrono::milliseconds(msecs));
+}