(helix) branch master updated: Align thread name when helix task executor are recreated.(#2999)

[xyuanlu]

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

xyuanlu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git


The following commit(s) were added to refs/heads/master by this push:
     new 886bc2492 Align thread name when helix task executor are 
recreated.(#2999)
886bc2492 is described below

commit 886bc2492906480a1faf51ad0a8bd03ddee7b2b2
Author: xyuanlu <xyua...@gmail.com>
AuthorDate: Tue Jan 21 13:07:47 2025 -0800

    Align thread name when helix task executor are recreated.(#2999)
    
    Align thread name when helix task executor are recreated.
---
 .../java/org/apache/helix/messaging/handling/HelixTaskExecutor.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
 
b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
index f006bd42b..c22322a2c 100644
--- 
a/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
+++ 
b/helix-core/src/main/java/org/apache/helix/messaging/handling/HelixTaskExecutor.java
@@ -769,7 +769,7 @@ public class HelixTaskExecutor implements MessageListener, 
TaskExecutor {
       MsgHandlerFactoryRegistryItem item = _hdlrFtyRegistry.get(msgType);
       ExecutorService pool = _executorMap.computeIfAbsent(msgType, type -> {
         ExecutorService newPool = 
Executors.newFixedThreadPool(item.threadPoolSize(),
-            r -> new Thread(r, "HelixTaskExecutor-message_handle_" + type));
+            r -> new Thread(r, "HelixTaskExecutor-message_handle_" + 
thread_uid.getAndIncrement()));
         _monitor.createExecutorMonitor(type, newPool);
         return newPool;
       });