From eb60c6ffe56dbeefd04810478ec60fa09e6a8bef Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Mon, 29 Nov 2021 20:09:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E7=BA=BF=E7=A8=8B?= =?UTF-8?q?=E6=B1=A0=E5=AE=9E=E6=97=B6=E5=8F=82=E6=95=B0=E6=9F=A5=E7=9C=8B?= =?UTF-8?q?,=20=E8=BF=94=E5=9B=9E=E6=9C=80=E5=90=8E=E5=88=B7=E6=96=B0?= =?UTF-8?q?=E6=97=B6=E9=97=B4.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/cn/hippo4j/common/model/PoolRunStateInfo.java | 5 +++++ .../hippo4j/starter/handler/ThreadPoolRunStateHandler.java | 3 +++ 2 files changed, 8 insertions(+) diff --git a/hippo4j-common/src/main/java/cn/hippo4j/common/model/PoolRunStateInfo.java b/hippo4j-common/src/main/java/cn/hippo4j/common/model/PoolRunStateInfo.java index 620c07a4..e47be3d0 100644 --- a/hippo4j-common/src/main/java/cn/hippo4j/common/model/PoolRunStateInfo.java +++ b/hippo4j-common/src/main/java/cn/hippo4j/common/model/PoolRunStateInfo.java @@ -100,4 +100,9 @@ public class PoolRunStateInfo implements Serializable { */ private String freeMemory; + /** + * clientLastRefreshTime + */ + private String clientLastRefreshTime; + } diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/handler/ThreadPoolRunStateHandler.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/handler/ThreadPoolRunStateHandler.java index e55e3dae..e3447e44 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/handler/ThreadPoolRunStateHandler.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/handler/ThreadPoolRunStateHandler.java @@ -6,12 +6,14 @@ import cn.hippo4j.starter.core.GlobalThreadPoolManage; import cn.hippo4j.starter.toolkit.ByteConvertUtil; import cn.hippo4j.starter.toolkit.CalculateUtil; import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.system.RuntimeInfo; import lombok.extern.slf4j.Slf4j; import java.net.InetAddress; import java.net.UnknownHostException; +import java.util.Date; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ThreadPoolExecutor; @@ -96,6 +98,7 @@ public class ThreadPoolRunStateHandler { ? ((DynamicThreadPoolExecutor) pool).getRejectCount() : -1; stateInfo.setRejectCount(rejectCount); + stateInfo.setClientLastRefreshTime(DateUtil.formatDateTime(new Date())); return stateInfo; }