eventdispatcher.h

main 67 lines · 2.6 KB Raw
Alex Alex Commit Client Upload Part 2 19/10/2026 00:06
1/*
2 * Copyright (c) 2010-2017 OTClient <https://github.com/edubart/otclient>
3 *
4 * Permission is hereby granted, free of charge, to any person obtaining a copy
5 * of this software and associated documentation files (the "Software"), to deal
6 * in the Software without restriction, including without limitation the rights
7 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8 * copies of the Software, and to permit persons to whom the Software is
9 * furnished to do so, subject to the following conditions:
10 *
11 * The above copyright notice and this permission notice shall be included in
12 * all copies or substantial portions of the Software.
13 *
14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
18 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
19 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
20 * THE SOFTWARE.
21 */
22
23#ifndef EVENTDISPATCHER_H
24#define EVENTDISPATCHER_H
25
26#include "clock.h"
27#include "scheduledevent.h"
28
29#include <queue>
30
31// @bindsingleton g_dispatcher
32class EventDispatcher
33{
34public:
35 void shutdown();
36 void poll();
37
38 EventPtr addEventEx(const std::string& function, const std::function<void()>& callback, bool pushFront = false);
39 ScheduledEventPtr scheduleEventEx(const std::string& function, const std::function<void()>& callback, int delay);
40 ScheduledEventPtr cycleEventEx(const std::string& function, const std::function<void()>& callback, int delay);
41
42 bool isBotSafe() { return m_botSafe; }
43
44private:
45 std::list<EventPtr> m_eventList;
46 int m_pollEventsSize;
47 bool m_disabled = false;
48 bool m_botSafe = false;
49 std::recursive_mutex m_mutex;
50 std::priority_queue<ScheduledEventPtr, std::vector<ScheduledEventPtr>, lessScheduledEvent> m_scheduledEventList;
51};
52
53extern EventDispatcher g_dispatcher;
54extern EventDispatcher g_graphicsDispatcher;
55extern std::thread::id g_mainThreadId;
56extern std::thread::id g_dispatcherThreadId;
57extern std::thread::id g_graphicsThreadId;
58
59#define addEvent(...) addEventEx(__FUNCTION__, __VA_ARGS__)
60#define scheduleEvent(...) scheduleEventEx(__FUNCTION__, __VA_ARGS__)
61#define cycleEvent(...) cycleEventEx(__FUNCTION__, __VA_ARGS__)
62
63#define VALIDATE_GRAPHICS_THREAD() VALIDATE(std::this_thread::get_id() == g_graphicsThreadId)
64#define VALIDATE_DISPATCHER_THREAD() VALIDATE(std::this_thread::get_id() == g_dispatcherThreadId)
65
66#endif
67
Top