impl ev io serve pool

Author: wuxiang

libev/include/singleton_base.h

@@ -22,11 +22,6 @@ class  singleton_base
 
 static _object_create  obj;
 
-private:
-    singleton_base()
-    {
-    }
-
 public:
 
     static _T&  instance()

libev/source/include/io_loop_pool.h

@@ -2,25 +2,25 @@
 #define _IO_LOOP_POOL_H_
 #include <vector>
 #include "loop.h"
+#include <memory>
 #include "singleton_base.h"
 
-class io_loop_pool: public singleton_base<io_loop_pool>
+class io_loop_pool//: public singleton_base<io_loop_pool>
 {
     public:
-        io_loop_pool& instance();
+        static io_loop_pool& instance();
         io_loop&   get_io_loop();
         bool  run();
         bool  stop();
 
     private:
         io_loop_pool(); 
-        io_loop_pool(const std::size_t& size);
         ~io_loop_pool();
 
-
     private:
-        std::size_t  m_size;
-        std::vector<io_loop>   m_pool;
+        std::size_t                              m_size;
+        std::size_t                              m_next;
+        std::vector<std::shared_ptr<io_loop> >   m_pool;
 };
 
 #endif //_IO_LOOP_POOL_H_

libev/source/src/configuration.cpp

@@ -101,7 +101,7 @@ void configuration::analyse(const std::vector<std::string>&  vstr)
 			std::size_t i = 0;
 			for (; i < strtmp.size(); ++i)
 			{
-				if (strtmp[i] == '=')
+				if (strtmp[i] == '=' || i == strtmp.size() - 1)
 				{
 					break;
 				}

libev/source/src/io_loop_pool.cpp

@@ -1 +1,54 @@
 #include "io_loop_pool.h"
+#include "configuration.h"
+
+io_loop_pool& io_loop_pool::instance()
+{
+    static io_loop_pool  pool;
+    return pool;
+}
+
+io_loop&   io_loop_pool::get_io_loop()
+{
+    if (m_next < m_size)
+    {
+        __sync_add_and_fetch(&m_next, 1);
+    }
+    else
+    {
+        m_next = 0;
+    }
+
+    return *m_pool[m_next];
+}
+
+bool  io_loop_pool::run()
+{
+    for (std::size_t i = 0; i < m_size; ++i)
+    {
+        m_pool[i]->run();
+    }
+    return true;
+}
+
+bool  io_loop_pool::stop()
+{
+    for (std::size_t i = 0; i < m_size; ++i)
+    {
+        m_pool[i]->stop();
+    }
+    return true;
+}
+
+io_loop_pool::io_loop_pool(): m_size(configuration::instance().get_ev_loop_size()), m_next(-1)
+{
+    for (std::size_t i = 0; i < m_size; ++i)
+    {
+        m_pool.push_back(std::shared_ptr<io_loop>(new (std::nothrow) io_loop()));
+    }
+}
+
+io_loop_pool::~io_loop_pool()
+{
+    stop();
+}
+