From f722a6b9291e1d10594cb242be3c967c40548c23 Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Sat, 20 Nov 2021 02:43:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=BA=BF=E7=A8=8B=E6=B1=A0?= =?UTF-8?q?=E7=BB=84=E4=BB=B6=E6=89=93=E5=8D=B0=E9=85=8D=E7=BD=AE=E5=8F=98?= =?UTF-8?q?=E6=9B=B4=E6=97=A5=E5=BF=97.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/ThreadPoolDynamicRefresh.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java index 41705bd2..7f38a445 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/core/ThreadPoolDynamicRefresh.java @@ -33,23 +33,23 @@ public class ThreadPoolDynamicRefresh { int originalCoreSize = executor.getCorePoolSize(); int originalMaximumPoolSize = executor.getMaximumPoolSize(); - int originalQueryType = parameter.getQueueType(); + String originalQuery = executor.getQueue().getClass().getSimpleName(); int originalCapacity = executor.getQueue().remainingCapacity() + executor.getQueue().size(); - long originalKeepAliveTime = executor.getKeepAliveTime(TimeUnit.MILLISECONDS); - int originalRejectedType = parameter.getRejectedType(); + long originalKeepAliveTime = executor.getKeepAliveTime(TimeUnit.SECONDS); + String originalRejected = executor.getRejectedExecutionHandler().getClass().getSimpleName(); changePoolInfo(executor, parameter); ThreadPoolExecutor afterExecutor = GlobalThreadPoolManage.getExecutorService(threadPoolId).getPool(); - log.info("[🔥 {}] Changed thread pool. coreSize :: [{}], maxSize :: [{}], queueType :: [{}], capacity :: [{}], keepAliveTime :: [{}], rejectedType :: [{}]", + log.info("[🔥 {}] Changed thread pool. \ncoreSize :: [{}], maxSize :: [{}], queueType :: [{}], capacity :: [{}], keepAliveTime :: [{}], rejectedType :: [{}]", threadPoolId.toUpperCase(), - String.format("%s=>%s", originalCoreSize, afterExecutor.getCorePoolSize()), - String.format("%s=>%s", originalMaximumPoolSize, afterExecutor.getMaximumPoolSize()), - String.format("%s=>%s", originalQueryType, parameter.getQueueType()), - String.format("%s=>%s", originalCapacity, + String.format("%s => %s", originalCoreSize, afterExecutor.getCorePoolSize()), + String.format("%s => %s", originalMaximumPoolSize, afterExecutor.getMaximumPoolSize()), + String.format("%s => %s", originalQuery, QueueTypeEnum.getBlockingQueueNameByType(parameter.getQueueType())), + String.format("%s => %s", originalCapacity, (afterExecutor.getQueue().remainingCapacity() + afterExecutor.getQueue().size())), - String.format("%s=>%s", originalKeepAliveTime, afterExecutor.getKeepAliveTime(TimeUnit.MILLISECONDS)), - String.format("%s=>%s", originalRejectedType, parameter.getRejectedType())); + String.format("%s => %s", originalKeepAliveTime, afterExecutor.getKeepAliveTime(TimeUnit.SECONDS)), + String.format("%s => %s", originalRejected, RejectedTypeEnum.getRejectedNameByType(parameter.getRejectedType()))); } public static void changePoolInfo(ThreadPoolExecutor executor, PoolParameterInfo parameter) {