Avoid repeated EventLoopThread::start

ithewei · Jul 19, 2024 · b350201 · b350201
1 parent 8c67e05
commit b350201
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/evpp/EventLoopThread.h b/evpp/EventLoopThread.h
@@ -44,6 +44,7 @@ class EventLoopThread : public Status {
                Functor pre = Functor(),
                Functor post = Functor()) {
         if (status() >= kStarting && status() < kStopped) return;
+        if (isRunning()) return;
         setStatus(kStarting);
 
         thread_ = std::make_shared<std::thread>(&EventLoopThread::loop_thread, this, pre, post);

diff --git a/evpp/TcpServer.h b/evpp/TcpServer.h
@@ -298,7 +298,9 @@ class TcpServerTmpl : private EventLoopThread, public TcpServerEventLoopTmpl<TSo
     // start thread-safe
     void start(bool wait_threads_started = true) {
         TcpServerEventLoopTmpl<TSocketChannel>::start(wait_threads_started);
-        EventLoopThread::start(wait_threads_started);
+        if (!isRunning()) {
+            EventLoopThread::start(wait_threads_started);
+        }
     }
 
     // stop thread-safe