[fix](exec) Add ++_get_waiting when USE_BTHREAD_SCANNER is defined.

kaka11chen · Nov 15, 2023 · 6c193f9 · 6c193f9
1 parent ea4b6e9
commit 6c193f9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/be/src/util/blocking_priority_queue.hpp b/be/src/util/blocking_priority_queue.hpp
@@ -87,6 +87,7 @@ class BlockingPriorityQueue {
             }
         } else {
             while (!(_shutdown || !_queue.empty())) {
+                ++_get_waiting;
                 _get_cv.wait(unique_lock);
             }
             wait_successful = true;
@@ -238,4 +239,4 @@ class BlockingPriorityQueue {
     size_t _put_waiting;
 };
 
-} // namespace doris
+} // namespace doris