handle messages concurrently

include/protocol.hpp

@@ -96,6 +96,7 @@ class draw_rectangle : public generic_message<Type::DRAW_RECTANGLE> {
   virtual void handle_message() override {
     spdlog::debug("draw_rectangle::handle_message()");
     spdlog::debug("Position: X = {}, Y = {}", position.x, position.y);
+    spdlog::debug("handle_message sleeps for 1 sec to test concurrency");
     std::this_thread::sleep_for(std::chrono::seconds(1));
   }
 
@@ -113,6 +114,7 @@ class draw_pixel : public generic_message<Type::DRAW_PIXEL> {
   virtual void handle_message() override {
     spdlog::debug("draw_pixel::handle_message()");
     spdlog::debug("Color: ({}, {}, {})", color.x, color.y, color.z);
+    spdlog::debug("handle_message sleeps for 1 sec to test concurrency");
     std::this_thread::sleep_for(std::chrono::seconds(1));
   }
 

include/server.hpp

@@ -2,6 +2,7 @@
 
 #include <boost/asio.hpp>
 #include <cstdlib>
+#include <future>
 #include <iostream>
 
 #include "protocol.hpp"
@@ -12,6 +13,15 @@ namespace commons {
 using boost::asio::ip::udp;
 using namespace protocol;
 
+class fake_thread_pool {
+ public:
+  template <typename Task>
+  static void add_task(Task&& task) {
+    std::thread t{std::forward<Task&&>(task)};
+    t.detach();
+  }
+};
+
 class server {
  public:
   server(boost::asio::io_context& io_context, short port)
@@ -25,14 +35,20 @@ class server {
         boost::asio::buffer(data_.data(), max_length), sender_endpoint_,
         [this](boost::system::error_code ec, std::size_t bytes_recvd) {
           if (!ec && bytes_recvd > 0) {
-            auto msg_obj = deserialize(data_.data(), bytes_recvd);
-            msg_obj->handle_message();
+            std::shared_ptr<protocol::generic_message_base> msg_obj =
+                deserialize(data_.data(), bytes_recvd);
 
-            do_send(bytes_recvd);
+            fake_thread_pool::add_task([msg_obj = std::move(msg_obj)]() {
+              msg_obj->handle_message();
+            });
+
+            // do_send(bytes_recvd);
             spdlog::debug("leaving do receive");
           } else {
-            do_receive();
+            spdlog::error("error during do receive");
           }
+
+          do_receive();
         });
   }