diff --git a/src/threaded_queue.hh b/src/threaded_queue.hh
index c2927640..bca221b8 100644
--- a/src/threaded_queue.hh
+++ b/src/threaded_queue.hh
@@ -46,6 +46,9 @@ private:
 
 struct MultiQueueWaiter {
   std::condition_variable_any cv;
+  ~MultiQueueWaiter() {
+	  cv.notify_all();
+  }
 
   static bool hasState(std::initializer_list<BaseThreadQueue *> queues) {
     for (BaseThreadQueue *queue : queues) {