Add "enqueued" state to base::task

Author: martincapello

base/task.cpp

@@ -36,6 +36,7 @@ task_token& task::start(thread_pool& pool)
 
   // Reset flags for a running task
   m_running = true;
+  m_enqueued = true;
   m_completed = false;
   m_token.reset();
 
@@ -45,6 +46,7 @@ task_token& task::start(thread_pool& pool)
 
 void task::in_worker_thread()
 {
+  m_enqueued = false;
   try {
     if (!m_token.canceled())
       m_execute(m_token);

base/task.h

@@ -67,6 +67,10 @@ class task {
 
   bool running() const { return m_running; }
 
+  // Returns true when the task is enqueued in the thread pool's work queue,
+  // and false when the task is actually being executed.
+  bool enqueued() const { return m_enqueued; }
+
   // Returns true when the task is completed (whether it was
   // canceled or not). If this is true, it's safe to delete the task
   // instance (it will not be used anymore by any othe background
@@ -77,6 +81,7 @@ class task {
   void in_worker_thread();
 
   std::atomic<bool> m_running;
+  std::atomic<bool> m_enqueued;
   std::atomic<bool> m_completed;
   task_token m_token;
   func_t m_execute;