[fix](stop)fix missing notify_all() after the stop (#27796)

2023-11-30 16:04:13 +08:00
parent 8ca8a0655e
commit f1846c10a1
1 changed files with 4 additions and 1 deletions
--- a/be/src/pipeline/pipeline_x/dependency.h
+++ b/be/src/pipeline/pipeline_x/dependency.h
@ -225,7 +225,10 @@ struct RuntimeFilterTimerQueue {
        _shutdown = true;
    }

-    void stop() { _stop = true; }
+    void stop() {
+        _stop = true;
+        cv.notify_all();
+    }

    void wait_for_shutdown() const {
        while (!_shutdown) {