summaryrefslogtreecommitdiff
path: root/src/common/Threading/Threading.h
blob: 8d1c7a186c1fc31616b2cadce4a254bf7e7b80db (plain)
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
/*
 * 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/>
 */

#ifndef THREADING_H
#define THREADING_H

#include <thread>
#include <atomic>

#include <thread>
#include <atomic>

namespace acore
{
    class Runnable
    {
    public:
        virtual ~Runnable() {}
        virtual void run() = 0;

        void incReference() { ++m_refs; }
        void decReference()
        {
            if (!--m_refs)
                delete this;
        }
    private:
        std::atomic_long m_refs;
    };

    enum Priority
    {
        Priority_Idle,
        Priority_Lowest,
        Priority_Low,
        Priority_Normal,
        Priority_High,
        Priority_Highest,
        Priority_Realtime,
    };

    class Thread
    {
    public:
        Thread();
        explicit Thread(Runnable* instance);
        ~Thread();

        bool wait();
        void destroy();

        void setPriority(Priority type);

        static void Sleep(unsigned long msecs);
        static std::thread::id currentId();

    private:
        Thread(const Thread&);
        Thread& operator=(const Thread&);

        static void ThreadTask(void* param);

        Runnable* const m_task;
        std::thread::id m_iThreadId;
        std::thread m_ThreadImp;
    };
}
#endif