Additional enhancements were made so that each event runs on an independent Thread

Author: Levent KARAGÖL

src/libcpp-event-hub.hpp

@@ -1,7 +1,7 @@
 /*
 
 Thread-safe generic event library for C++ (17+)
-version 1.0.0
+version 1.1.0
 https://github.com/leventkaragol/libcpp-event-hub
 
 If you encounter any issues, please submit a ticket at https://github.com/leventkaragol/libcpp-event-hub/issues
@@ -38,6 +38,7 @@ SOFTWARE.
 #include <any>
 #include <iostream>
 #include <mutex>
+#include <future>
 
 namespace lklibs
 {
@@ -81,15 +82,21 @@ namespace lklibs
             {
                 for (const auto& [id, listener] : listeners_.at(eventName))
                 {
-                    listener(eventName, sender, eventData);
+                    std::thread([listener, eventName, sender, eventData]()
+                    {
+                        listener(eventName, sender, eventData);
+                    }).detach();
                 }
             }
 
             if (listeners_.find("*") != listeners_.end())
             {
                 for (const auto& [id, listener] : listeners_.at("*"))
                 {
-                    listener(eventName, sender, eventData);
+                    std::thread([listener, eventName, sender, eventData]()
+                    {
+                        listener(eventName, sender, eventData);
+                    }).detach();
                 }
             }
         }
@@ -107,7 +114,7 @@ namespace lklibs
         {
             std::unique_lock lock(mutex_);
 
-            auto id = nextListenerId_++;
+            const auto id = nextListenerId_++;
 
             auto wrappedListener = [listener](const std::string& eventName, const std::string& sender, const std::any& data)
             {

test/test.cpp

@@ -1,6 +1,7 @@
 #include <gtest/gtest.h>
 #include "libcpp-event-hub.hpp"
 #include <string>
+#include <thread>
 
 using namespace lklibs;
 
@@ -21,6 +22,8 @@ TEST(EventHubTest, AddListenerAndEmitString)
 
     eventHub.emit("testEvent", "testSender", std::string("testData"));
 
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+
     EXPECT_TRUE(listenerCalled);
 
     eventHub.removeListener("testEvent", listenerId);
@@ -43,6 +46,8 @@ TEST(EventHubTest, AddListenerAndEmitInt)
 
     eventHub.emit("testEvent", "testSender", 7);
 
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+
     EXPECT_TRUE(listenerCalled);
 
     eventHub.removeListener("testEvent", listenerId);
@@ -75,6 +80,8 @@ TEST(EventHubTest, GeneralListener)
 
     eventHub.emit("testEvent", "testSender", std::string("testData"));
 
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+
     EXPECT_TRUE(generalListenerCalled);
     EXPECT_TRUE(specificListenerCalled);
 
@@ -97,6 +104,8 @@ TEST(EventHubTest, RemoveListener)
 
     eventHub.emit("testEvent", "testSender", std::string("testData"));
 
+    std::this_thread::sleep_for(std::chrono::milliseconds(100));
+
     EXPECT_FALSE(listenerCalled);
 }