diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolAdapterRegister.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolAdapterRegister.java index eaf33f08..21798532 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolAdapterRegister.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolAdapterRegister.java @@ -66,8 +66,6 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { private List cacheConfigList = Lists.newArrayList(); - - @Override public void run(ApplicationArguments args) throws Exception { @@ -77,7 +75,7 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { scheduler.schedule(threadPoolAdapterRegisterTask, threadPoolAdapterScheduler.getTaskIntervalSeconds(), TimeUnit.SECONDS); } - public List getThreadPoolAdapterCacheConfigs(){ + public List getThreadPoolAdapterCacheConfigs() { Map threadPoolAdapterMap = ApplicationContextHolder.getBeansOfType(ThreadPoolAdapter.class); List cacheConfigList = Lists.newArrayList(); threadPoolAdapterMap.forEach((key, val) -> { @@ -98,7 +96,7 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { return cacheConfigList; } - public void doRegister(List cacheConfigList){ + public void doRegister(List cacheConfigList) { if (CollectionUtil.isNotEmpty(cacheConfigList)) { try { Result result = httpAgent.httpPost(REGISTER_ADAPTER_PATH, cacheConfigList); @@ -116,13 +114,13 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { doRegister(threadPoolAdapterCacheConfigs); } - class ThreadPoolAdapterRegisterTask implements Runnable{ + class ThreadPoolAdapterRegisterTask implements Runnable { private ScheduledExecutorService scheduler; private int taskIntervalSeconds; - public ThreadPoolAdapterRegisterTask(ScheduledExecutorService scheduler, int taskIntervalSeconds){ + public ThreadPoolAdapterRegisterTask(ScheduledExecutorService scheduler, int taskIntervalSeconds) { this.scheduler = scheduler; this.taskIntervalSeconds = taskIntervalSeconds; } @@ -139,9 +137,9 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { if (registerFlag) { doRegister(cacheConfigList); } - }catch (Exception e){ - log.error("Register Task Error",e); - }finally { + } catch (Exception e) { + log.error("Register Task Error", e); + } finally { if (!scheduler.isShutdown()) { scheduler.schedule(this, taskIntervalSeconds, TimeUnit.MILLISECONDS); } @@ -150,7 +148,7 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { } private boolean compareThreadPoolAdapterCacheConfigs(List newThreadPoolAdapterCacheConfigs, - List oldThreadPoolAdapterCacheConfigs){ + List oldThreadPoolAdapterCacheConfigs) { boolean registerFlag = false; Map> newThreadPoolAdapterCacheConfigMap = @@ -168,7 +166,7 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner { if (oldValue == null) { registerFlag = true; break; - }else { + } else { if (newValue.size() != oldValue.size()) { registerFlag = true; break;