fix: Task dispatcher handle busy and other issues

mfavant · Aug 18, 2023 · 34f9bbe · 34f9bbe
1 parent 055c922
commit 34f9bbe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 11 deletions.
diff --git a/src/thread/task_dispatcher.h b/src/thread/task_dispatcher.h
@@ -90,17 +90,7 @@ namespace tubekit
         {
             singleton<logger>::instance()->debug(__FILE__, __LINE__, "task dispatcher handle task");
             thread_pool<THREAD, TASK> *pool = singleton<thread_pool<THREAD, TASK>>::instance();
-            if (pool->get_idle_thread_numbers() > 0)
-            {
-                pool->assign(m_task);
-            }
-            else
-            {
-                m_mutex.lock();
-                m_tasks.push_front(m_task); // If there are no free threads, they are put into the list first
-                m_mutex.unlock();
-                singleton<logger>::instance()->debug(__FILE__, __LINE__, "all threads are busy");
-            }
+            pool->assign(m_task);
         }
 
         template <typename THREAD, typename TASK>

diff --git a/src/thread/thread_pool.h b/src/thread/thread_pool.h
@@ -57,6 +57,8 @@ namespace tubekit
              */
             void assign(TASK *m_task);
 
+            void wait_exist_idle();
+
         private:
             /**
              * @brief number of threads in pool