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 <98214048+dataroar...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
