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