summaryrefslogtreecommitdiffstats
path: root/src/Event.cpp
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/Event.cpp49
1 files changed, 49 insertions, 0 deletions
diff --git a/src/Event.cpp b/src/Event.cpp
index 00f67c0..c857947 100644
--- a/src/Event.cpp
+++ b/src/Event.cpp
@@ -1 +1,50 @@
#include "Event.hpp"
+
+std::list<EventListener*> EventSystem::listeners;
+std::mutex EventSystem::listenersMutex;
+
+EventListener::EventListener() {
+ std::lock_guard<std::mutex> listenersLock(EventSystem::listenersMutex);
+ EventSystem::listeners.push_back(this);
+}
+
+EventListener::~EventListener() {
+ std::lock_guard<std::mutex> listenersLock(EventSystem::listenersMutex);
+ EventSystem::listeners.remove(this);
+}
+
+void EventListener::HandleEvent() {
+ std::lock_guard<std::mutex> lock(eventsQueueMutex);
+ std::lock_guard<std::mutex> lockHandlers(handlersMutex);
+ Event event = events.front();
+ events.pop();
+ if (handlers[event.id]) {
+ handlers[event.id](event);
+ }
+}
+
+void EventListener::HandleAllEvents() {
+ std::lock_guard<std::mutex> lock(eventsQueueMutex);
+ std::lock_guard<std::mutex> lockHandlers(handlersMutex);
+ while (!events.empty()) {
+ Event event = events.front();
+ events.pop();
+ if (handlers[event.id]) {
+ handlers[event.id](event);
+ }
+ }
+}
+
+bool EventListener::NotEmpty() {
+ std::lock_guard<std::mutex> lock(eventsQueueMutex);
+ return !events.empty();
+}
+
+void EventListener::WaitEvent() {
+ eventsQueueMutex.lock();
+ while (events.empty()) {
+ eventsQueueMutex.unlock();
+ eventsQueueMutex.lock();
+ }
+ eventsQueueMutex.unlock();
+} \ No newline at end of file