diff --git a/common/concurrent_queue.h b/common/concurrent_queue.h
index 5b92f6f1..86bbcdcf 100644
--- a/common/concurrent_queue.h
+++ b/common/concurrent_queue.h
@@ -45,7 +45,7 @@ public:
 
     void cancellPending()
     {
-        std::unique_lock<std::mutex> lock(jobsLeftMutex);
+        std::unique_lock<std::mutex> lock(queueMutex);
         _queue = std::queue<std::function<void(void)>>();
         jobsLeft = 0;
     }