diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/config/CommonConfig.java b/hippo4j-config/src/main/java/cn/hippo4j/config/config/CommonConfig.java index 4084022c..8ccd178f 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/config/CommonConfig.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/config/CommonConfig.java @@ -26,6 +26,7 @@ public class CommonConfig { @Primary public ThreadPoolTaskExecutor monitorThreadPoolTaskExecutor() { ThreadPoolTaskExecutor monitorThreadPool = new ThreadPoolTaskExecutor(); + monitorThreadPool.setThreadNamePrefix("server.monitor.executor."); monitorThreadPool.setCorePoolSize(AVAILABLE_PROCESSORS); monitorThreadPool.setMaxPoolSize(AVAILABLE_PROCESSORS << 1); monitorThreadPool.setQueueCapacity(4096); diff --git a/hippo4j-config/src/main/java/cn/hippo4j/config/toolkit/ConfigExecutor.java b/hippo4j-config/src/main/java/cn/hippo4j/config/toolkit/ConfigExecutor.java index e8187404..88840e08 100644 --- a/hippo4j-config/src/main/java/cn/hippo4j/config/toolkit/ConfigExecutor.java +++ b/hippo4j-config/src/main/java/cn/hippo4j/config/toolkit/ConfigExecutor.java @@ -17,7 +17,7 @@ import static cn.hippo4j.common.constant.Constants.DEFAULT_GROUP; public class ConfigExecutor { private static final ScheduledExecutorService LONG_POLLING_EXECUTOR = ExecutorFactory.Managed - .newSingleScheduledExecutorService(DEFAULT_GROUP, r -> new Thread(r, "long-polling")); + .newSingleScheduledExecutorService(DEFAULT_GROUP, r -> new Thread(r, "server.long.polling")); public static void executeLongPolling(Runnable runnable) { LONG_POLLING_EXECUTOR.execute(runnable);