[doris] 01/04: [fix](delete) notify all when there is no high priority task (#19577)

[mo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 4a223c3b2241b872df060e8e06f1db8ffd756993
Author: Yongqiang YANG <98...@users.noreply.github.com>
AuthorDate: Tue May 16 11:29:10 2023 +0800

    [fix](delete) notify all when there is no high priority task (#19577)
    
    In somecases high priority threads are waked but normal are not. We
    notify_all as a workaround.
---
 be/src/agent/task_worker_pool.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/be/src/agent/task_worker_pool.cpp b/be/src/agent/task_worker_pool.cpp
index f835dd4d14..133a3345a5 100644
--- a/be/src/agent/task_worker_pool.cpp
+++ b/be/src/agent/task_worker_pool.cpp
@@ -602,7 +602,7 @@ void TaskWorkerPool::_push_worker_thread_callback() {
 
             if (index < 0) {
                 // there is no high priority task. notify other thread to handle normal task
-                _worker_thread_condition_variable.notify_one();
+                _worker_thread_condition_variable.notify_all();
                 break;
             }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org