issue #1 use a boost::asio::io_service::work object to keep the io_se…

…rvice::run loop alive
Cylix · Nov 15, 2015 · f08d987 · f08d987
1 parent b96dd15
commit f08d987
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/examples/redis_client.cpp b/examples/redis_client.cpp
@@ -3,7 +3,7 @@
 #include <signal.h>
 #include <iostream>
 
-bool should_exit = false;
+volatile std::atomic_bool should_exit(false);
 cpp_redis::redis_client client;
 
 void

diff --git a/includes/cpp_redis/network/io_service.hpp b/includes/cpp_redis/network/io_service.hpp
@@ -11,7 +11,7 @@ namespace network {
 class io_service {
 public:
     //! ctor & dtor
-    io_service(void) = default;
+    io_service(void);
     ~io_service(void);
 
     //! copy ctor & assignment operator
@@ -28,6 +28,7 @@ class io_service {
 
 private:
     boost::asio::io_service m_io_service;
+    boost::asio::io_service::work m_work;
     std::thread m_io_service_thread;
 };
 

diff --git a/sources/network/io_service.cpp b/sources/network/io_service.cpp
@@ -4,9 +4,14 @@ namespace cpp_redis {
 
 namespace network {
 
+io_service::io_service(void)
+: m_work(m_io_service) {}
+
 io_service::~io_service(void) {
-    if (m_io_service_thread.joinable())
+    if (m_io_service_thread.joinable()) {
+        m_io_service.stop();
         m_io_service_thread.join();
+    }
 }
 
 void