When threadpool size is 0, using photon::thread_create directly

Signed-off-by: Coldwings <coldwings@me.com>
alibaba · Jan 9, 2024 · 2b6d511 · 2b6d511
1 parent 9274ed4
commit 2b6d511
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/thread/thread-pool.cpp b/thread/thread-pool.cpp
@@ -32,7 +32,7 @@ namespace photon
 
     TPControl* ThreadPoolBase::thread_create_ex(thread_entry start, void* arg, bool joinable)
     {
-        if (__should_bypass_threadpool()) {
+        if (m_capacity == 0 || __should_bypass_threadpool()) {
             auto th = photon::thread_create(start, arg, (uint64_t)m_reserved,
                                             sizeof(TPControl));
             auto pCtrl = photon::thread_reserved_space<TPControl>(th);
@@ -129,7 +129,7 @@ namespace photon
     }
     void ThreadPoolBase::join(TPControl* pCtrl)
     {
-        if (__should_bypass_threadpool()) {
+        if (m_capacity == 0 || __should_bypass_threadpool()) {
             photon::thread_join((photon::join_handle*)pCtrl->th);
             return;
         }