IOThreadTcpService::startWorkerThread return eventloop list

Author: IronsDu

include/brynet/net/TcpService.hpp

@@ -33,10 +33,10 @@ class IOThreadTcpService : public ITcpService,
         return std::make_shared<make_shared_enabler>();
     }
 
-    void startWorkerThread(size_t threadNum,
-                           FrameCallback callback = nullptr)
+    std::vector<brynet::net::EventLoop::Ptr> startWorkerThread(size_t threadNum,
+                                                               FrameCallback callback = nullptr)
     {
-        detail::TcpServiceDetail::startWorkerThread(threadNum, callback);
+        return detail::TcpServiceDetail::startWorkerThread(threadNum, callback);
     }
 
     void stopWorkerThread()

include/brynet/net/detail/TCPServiceDetail.hpp

@@ -66,15 +66,17 @@ class TcpServiceDetail : public brynet::base::NonCopyable
         stopWorkerThread();
     }
 
-    void startWorkerThread(size_t threadNum,
-                           FrameCallback callback = nullptr)
+    std::vector<brynet::net::EventLoop::Ptr> startWorkerThread(size_t threadNum,
+                                                               FrameCallback callback = nullptr)
     {
+        std::vector<brynet::net::EventLoop::Ptr> eventLoops;
+
         std::lock_guard<std::mutex> lck(mServiceGuard);
         std::lock_guard<std::mutex> lock(mIOLoopGuard);
 
         if (!mIOLoopDatas.empty())
         {
-            return;
+            return eventLoops;
         }
 
         mRunIOLoop = std::make_shared<bool>(true);
@@ -84,6 +86,8 @@ class TcpServiceDetail : public brynet::base::NonCopyable
         for (auto& v : mIOLoopDatas)
         {
             auto eventLoop = std::make_shared<EventLoop>();
+            eventLoops.push_back(eventLoop);
+
             auto runIoLoop = mRunIOLoop;
             wg->add(1);
             v = IOLoopData::Create(eventLoop,
@@ -103,6 +107,8 @@ class TcpServiceDetail : public brynet::base::NonCopyable
                                            }));
         }
         wg->wait();
+
+        return eventLoops;
     }
 
     void stopWorkerThread()