1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/*
* Copyright (C) 2016+ AzerothCore <www.azerothcore.org>, released under GNU GPL v2 license: https://github.com/azerothcore/azerothcore-wotlk/blob/master/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>
#ifdef WIN32
#include <windows.h>
#endif // WIN32
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));
}
|
