diff --git a/include/mcut/internal/tpool.h b/include/mcut/internal/tpool.h
index 3ab545a..f15e875 100644
--- a/include/mcut/internal/tpool.h
+++ b/include/mcut/internal/tpool.h
@@ -204,7 +204,7 @@ class thread_safe_queue {
             tail->next = std::move(p);
             tail = new_tail;
         }
-        data_cond.notify_one();
+        disrupt_wait_for_data();
     }
 
     void wait_and_pop(T& value)
@@ -1029,4 +1029,4 @@ T mc_atomic_fetch_add(std::atomic<T>* obj, T arg) {
     return expected;
 }
 
-#endif // MCUT_SCHEDULER_H_
\ No newline at end of file
+#endif // MCUT_SCHEDULER_H_