调整动态刷新日志打印.

pull/142/head
chen.ma 2 years ago
parent 17ab730e71
commit ca68742a13

@ -57,7 +57,9 @@ public class JettyWebThreadPoolHandler extends AbstractWebThreadPoolService {
jettyExecutor.setMaxThreads(maxSize);
log.info(
"🔥 Changed web thread pool. coreSize :: [{}], maxSize :: [{}]",
"[JETTY] Changed web thread pool. " +
"\n coreSize :: [{}]" +
"\n maxSize :: [{}]",
String.format("%s => %s", minThreads, jettyExecutor.getMinThreads()),
String.format("%s => %s", maxThreads, jettyExecutor.getMaxThreads())
);

@ -77,7 +77,10 @@ public class TomcatWebThreadPoolHandler extends AbstractWebThreadPoolService {
tomcatExecutor.setMaximumPoolSize(poolParameterInfo.getMaxSize());
tomcatExecutor.setKeepAliveTime(poolParameterInfo.getKeepAliveTime(), TimeUnit.SECONDS);
log.info(
"🔥 Changed web thread pool. coreSize :: [{}], maxSize :: [{}], keepAliveTime :: [{}]",
"[TOMCAT] Changed web thread pool. " +
"\n coreSize :: [{}]" +
"\n maxSize :: [{}]" +
"\n keepAliveTime :: [{}]",
String.format("%s => %s", originalCoreSize, poolParameterInfo.getCoreSize()),
String.format("%s => %s", originalMaximumPoolSize, poolParameterInfo.getMaxSize()),
String.format("%s => %s", originalKeepAliveTime, poolParameterInfo.getKeepAliveTime())

@ -73,7 +73,10 @@ public class UndertowWebThreadPoolHandler extends AbstractWebThreadPoolService {
xnioWorker.setOption(Options.WORKER_TASK_MAX_THREADS, maxSize);
xnioWorker.setOption(Options.WORKER_TASK_KEEPALIVE, keepAliveTime);
log.info(
"🔥 Changed web thread pool. coreSize :: [{}], maxSize :: [{}], keepAliveTime :: [{}]",
"[UNDERTOW] Changed web thread pool. " +
"\n coreSize :: [{}]" +
"\n maxSize :: [{}]" +
"\n keepAliveTime :: [{}]",
String.format("%s => %s", originalCoreSize, coreSize),
String.format("%s => %s", originalMaximumPoolSize, maxSize),
String.format("%s => %s", originalKeepAliveTime, keepAliveTime)

@ -153,7 +153,7 @@ public abstract class AbstractCoreThreadPoolDynamicRefresh implements ThreadPool
GlobalCoreThreadPoolManage.refresh(threadPoolId, properties);
log.info(
"[🔥 {}] Changed thread pool. " +
"[{}] Changed thread pool. " +
"\n coreSize :: [{}]" +
"\n maxSize :: [{}]" +
"\n queueType :: [{}]" +

@ -94,7 +94,7 @@ public class ServerThreadPoolDynamicRefresh implements ThreadPoolDynamicRefresh
threadPoolNotifyAlarmHandler.sendPoolConfigChange(request);
log.info(
"[🔥 {}] Changed thread pool. " +
"[{}] Changed thread pool. " +
"\n coreSize :: [{}]" +
"\n maxSize :: [{}]" +
"\n queueType :: [{}]" +

@ -73,7 +73,7 @@ public abstract class AbstractHealthCheck implements ServerHealthCheck, Initiali
if (healthCheckStatus) {
if (Objects.equals(healthStatus, false)) {
healthStatus = true;
log.info("🚀 The client reconnects to the server successfully.");
log.info("The client reconnects to the server successfully.");
signalAllBizThread();
}
} else {

Loading…
Cancel
Save