utils:workqueue: add CancelScheduledWork() function

this function discards qeueud works in works list to cancel queued job;

2 files changed, 9 insertions, 1 deletions

diff --git a/utils/inc/workqueue.h b/utils/inc/workqueue.h
index 20f4bc1..712e071 100644
--- a/utils/inc/workqueue.h
+++ b/utils/inc/workqueue.h
@@ -40,7 +40,8 @@ public:
      *  the class.
      */
     void FlushWork(void);
-    //void CancelWork(WorkableInterface *wi);
+    /* remove all scheduled works matched with wi from workqueue list */
+    void CancelScheduledWork(WorkableInterface *wi);
 
 private:
     /* inner class for flushing */
diff --git a/utils/src/workqueue.cpp b/utils/src/workqueue.cpp
index 6e281e1..2b5e47b 100644
--- a/utils/src/workqueue.cpp
+++ b/utils/src/workqueue.cpp
@@ -94,6 +94,13 @@ void WorkQueue::ScheduleWork(WorkableInterface *wi)
     pthread_mutex_unlock(&wlock);
 }
 
+void WorkQueue::CancelScheduledWork(WorkableInterface *wi)
+{
+    pthread_mutex_lock(&wlock);
+    works = list_delete_all(works, wi);
+    pthread_mutex_unlock(&wlock);
+}
+
 void WorkQueue::FlushWork(void)
 {
     FlushBarrier fb;