Updated mutithreaded example

Grzegorz Jabłoński
1 parent a8ad056a
Showing 1 changed file with 8 additions and 12 deletions
13-daytime8.cpp
@@ -15,8 +15,6 @@
 using asio::ip::tcp;
-std::shared_ptr<asio::io_context> io_context;
-
 std::string make_daytime_string() {
   using namespace std; // For time_t, time and ctime;
   time_t now = time(0);
@@ -38,20 +36,18 @@ public:
   tcp::socket &socket() { return socket_; }
   void start() {
-    io_context->post([self = shared_from_this()] {
-      self->message_ = make_daytime_string();
-      asio::async_write(self->socket_, asio::buffer(self->message_),
-                        std::bind(&tcp_connection::handle_write, self,
-                                  std::placeholders::_1,
-                                  std::placeholders::_2));
-    });
+    message_ = make_daytime_string();
+    asio::async_write(socket_, asio::buffer(message_),
+                      std::bind(&tcp_connection::handle_write, this,
+                                std::placeholders::_1, std::placeholders::_2));
   }
 private:
   tcp_connection(asio::io_context &io_context) : socket_(io_context) {}
   void handle_write(const asio::error_code &error, size_t bytes_transferred) {
-    std::cout << error.category().name() << " : " << error.value() << " : " << error.message() << std::endl;
+    std::cout << error.category().name() << " : " << error.value() << " : "
+              << error.message() << std::endl;
     if (error)
       std::cout << "Error" << std::endl;
     else
@@ -83,7 +79,7 @@ private:
   void handle_accept(tcp_connection::pointer new_connection,
                      const asio::error_code &error) {
     if (!error) {
-      new_connection->start();
+      io_context_.post(std::bind(&tcp_connection::start, new_connection));
     }
     start_accept();
@@ -97,7 +93,7 @@ void WorkerThread(std::shared_ptr&lt;asio::io_context&gt; io_svc) { io_svc-&gt;run(); }
 int main() {
   try {
-    io_context = std::make_shared<asio::io_context>();
+    auto io_context = std::make_shared<asio::io_context>();
     auto worker = std::make_shared<asio::io_context::work>(*io_context);