diff --git a/src/rdb.cpp b/src/rdb.cpp index ad2823197..92a466f68 100644 --- a/src/rdb.cpp +++ b/src/rdb.cpp @@ -2419,7 +2419,7 @@ public: for (;;) { std::unique_lock lock(queue.mutex); if (queue.queuejobs.empty() && queue.queuefn.empty()) { - if (queue.fExit) + if (queue.queuejobs.empty() && queue.queuefn.empty() && queue.fExit) break; queue.cv.wait(lock); if (queue.queuejobs.empty() && queue.queuefn.empty() && queue.fExit)