From fa32e7a9f46c7da39a527d0ebc049e3720068d8e Mon Sep 17 00:00:00 2001
From: LaG1924 <12997935+LaG1924@users.noreply.github.com>
Date: Fri, 29 Dec 2017 17:09:51 +0500
Subject: Implemented new event system

---
 src/Event.cpp | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)

(limited to 'src/Event.cpp')

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
-- 
cgit v1.2.3