This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit e71e1b6f303bd2fbc5d558e6f8ad7080dacf31e7 Author: yiguolei <[email protected]> AuthorDate: Sun Mar 24 18:41:05 2024 +0800 [enhancement](threadname) change thread name more simple in order to see it in top -H (#31734) Co-authored-by: yiguolei <[email protected]> --- be/src/agent/task_worker_pool.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/be/src/agent/task_worker_pool.cpp b/be/src/agent/task_worker_pool.cpp index 4921f4585f5..7c798a18a97 100644 --- a/be/src/agent/task_worker_pool.cpp +++ b/be/src/agent/task_worker_pool.cpp @@ -406,7 +406,7 @@ bvar::Adder<uint64_t> report_tablet_failed("report", "tablet_failed"); TaskWorkerPool::TaskWorkerPool(std::string_view name, int worker_count, std::function<void(const TAgentTaskRequest& task)> callback) : _callback(std::move(callback)) { - auto st = ThreadPoolBuilder(fmt::format("TaskWorkerPool.{}", name)) + auto st = ThreadPoolBuilder(fmt::format("TaskWP_{}", name)) .set_min_threads(worker_count) .set_max_threads(worker_count) .build(&_thread_pool); @@ -441,7 +441,7 @@ PriorTaskWorkerPool::PriorTaskWorkerPool( std::string_view name, int normal_worker_count, int high_prior_worker_conut, std::function<void(const TAgentTaskRequest& task)> callback) : _callback(std::move(callback)) { - auto st = ThreadPoolBuilder(fmt::format("TaskWorkerPool.{}", name)) + auto st = ThreadPoolBuilder(fmt::format("TaskWP_.{}", name)) .set_min_threads(normal_worker_count) .set_max_threads(normal_worker_count) .build(&_normal_pool); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
