diff --git a/src/common/task_queue.h b/src/common/task_queue.h index 0f4870c..65d85fb 100644 --- a/src/common/task_queue.h +++ b/src/common/task_queue.h @@ -104,6 +104,8 @@ class TaskQueue { [this]() { return stop_; }); } + if (stop_ && taskQueue_.empty()) return; + task = std::move( const_cast &>(taskQueue_.top().task)); taskQueue_.pop();