From e71e1b6f303bd2fbc5d558e6f8ad7080dacf31e7 Mon Sep 17 00:00:00 2001 From: yiguolei <676222867@qq.com> Date: Sun, 24 Mar 2024 18:41:05 +0800 Subject: [PATCH] [enhancement](threadname) change thread name more simple in order to see it in top -H (#31734) Co-authored-by: yiguolei --- 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 4921f4585f..7c798a18a9 100644 --- a/be/src/agent/task_worker_pool.cpp +++ b/be/src/agent/task_worker_pool.cpp @@ -406,7 +406,7 @@ bvar::Adder report_tablet_failed("report", "tablet_failed"); TaskWorkerPool::TaskWorkerPool(std::string_view name, int worker_count, std::function 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 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);