[helix] branch master updated: Simplify thread naming in TaskStateModelFactory" (#2507)

[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 3ff103389 Simplify thread naming in TaskStateModelFactory" (#2507)
3ff103389 is described below

commit 3ff1033891511e8b15b4a2bd3f2338c5efb6dba3
Author: Komal Desai <98000016+desaiko...@users.noreply.github.com>
AuthorDate: Thu May 25 17:25:53 2023 -0700

    Simplify thread naming in TaskStateModelFactory" (#2507)
    
    Simplify thread naming in TaskStateModelFactory.
    
    ---------
    
    Co-authored-by: Komal Desai <kde...@kdesai-mn1.linkedin.biz>
---
 .../java/org/apache/helix/task/TaskStateModelFactory.java   | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

diff --git 
a/helix-core/src/main/java/org/apache/helix/task/TaskStateModelFactory.java 
b/helix-core/src/main/java/org/apache/helix/task/TaskStateModelFactory.java
index 7b9dd74e1..b8474b792 100644
--- a/helix-core/src/main/java/org/apache/helix/task/TaskStateModelFactory.java
+++ b/helix-core/src/main/java/org/apache/helix/task/TaskStateModelFactory.java
@@ -25,10 +25,10 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.atomic.AtomicInteger;
 import javax.management.JMException;
 
 import com.google.common.annotations.VisibleForTesting;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import org.apache.helix.HelixException;
 import org.apache.helix.HelixManager;
 import org.apache.helix.SystemPropertyKeys;
@@ -45,7 +45,6 @@ import 
org.apache.helix.zookeeper.impl.factory.SharedZkClientFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
 /**
  * Factory class for {@link TaskStateModel}.
  */
@@ -191,13 +190,7 @@ public class TaskStateModelFactory extends 
StateModelFactory<TaskStateModel> {
     LOG.info(
         "Obtained target thread pool size: {} from cluster {} for instance {}. 
Creating thread pool.",
         targetThreadPoolSize, manager.getClusterName(), 
manager.getInstanceName());
-    return Executors.newScheduledThreadPool(targetThreadPoolSize, new 
ThreadFactory() {
-      private AtomicInteger threadId = new AtomicInteger(0);
-
-      @Override
-      public Thread newThread(Runnable r) {
-        return new Thread(r, "TaskStateModelFactory-task_thread-" + 
threadId.getAndIncrement());
-      }
-    });
+    return Executors.newScheduledThreadPool(targetThreadPoolSize,
+            new 
ThreadFactoryBuilder().setNameFormat("TaskStateModelFactory-task_thread-%d").build());
   }
 }