客户端线程池实时参数查看, 返回最后刷新时间.

pull/12/head
chen.ma 3 years ago
parent bbb10ee4c9
commit eb60c6ffe5

@ -100,4 +100,9 @@ public class PoolRunStateInfo implements Serializable {
*/ */
private String freeMemory; private String freeMemory;
/**
* clientLastRefreshTime
*/
private String clientLastRefreshTime;
} }

@ -6,12 +6,14 @@ import cn.hippo4j.starter.core.GlobalThreadPoolManage;
import cn.hippo4j.starter.toolkit.ByteConvertUtil; import cn.hippo4j.starter.toolkit.ByteConvertUtil;
import cn.hippo4j.starter.toolkit.CalculateUtil; import cn.hippo4j.starter.toolkit.CalculateUtil;
import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper; import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import cn.hutool.system.RuntimeInfo; import cn.hutool.system.RuntimeInfo;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.Date;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
@ -96,6 +98,7 @@ public class ThreadPoolRunStateHandler {
? ((DynamicThreadPoolExecutor) pool).getRejectCount() ? ((DynamicThreadPoolExecutor) pool).getRejectCount()
: -1; : -1;
stateInfo.setRejectCount(rejectCount); stateInfo.setRejectCount(rejectCount);
stateInfo.setClientLastRefreshTime(DateUtil.formatDateTime(new Date()));
return stateInfo; return stateInfo;
} }

Loading…
Cancel
Save