代码优化.

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/pom.xml

@@ -73,19 +73,6 @@
             <optional>true</optional>
         </dependency>
 
-        <dependency>
-            <groupId>com.guicedee.services</groupId>
-            <artifactId>commons-lang3</artifactId>
-            <version>1.2.1.1-jre17</version>
-            <scope>compile</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>16.0.1</version>
-        </dependency>
-
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-configuration-processor</artifactId>

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/notify/CoreNotifyConfigBuilder.java

@@ -32,11 +32,12 @@ public class CoreNotifyConfigBuilder implements NotifyConfigBuilder {
         Map<String, List<NotifyConfigDTO>> resultMap = Maps.newHashMap();
 
         List<ExecutorProperties> executors = bootstrapCoreProperties.getExecutors();
-        if (null !=executors) {
+        if (null != executors) {
             for (ExecutorProperties executor : executors) {
                 resultMap.putAll(buildSingleNotifyConfig(executor));
             }
         }
+
         return resultMap;
     }
 

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/refresher/AbstractCoreThreadPoolDynamicRefresh.java

@@ -92,7 +92,6 @@ public abstract class AbstractCoreThreadPoolDynamicRefresh implements ThreadPool
             threadPoolNotifyAlarm.setReceives(executorProperties.getNotify().getReceives());
             GlobalNotifyAlarmManage.put(executorProperties.getThreadPoolId(), threadPoolNotifyAlarm);
         });
-
     }
 
     /**

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/refresher/ZookeeperRefresherHandler.java

@@ -4,8 +4,6 @@ import cn.hippo4j.core.executor.ThreadPoolNotifyAlarmHandler;
 import cn.hippo4j.core.starter.config.BootstrapCoreProperties;
 import com.google.common.base.Charsets;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.tuple.ImmutablePair;
-import org.apache.commons.lang3.tuple.Pair;
 import org.apache.curator.framework.CuratorFramework;
 import org.apache.curator.framework.CuratorFrameworkFactory;
 import org.apache.curator.framework.api.CuratorListener;
@@ -45,7 +43,8 @@ public class ZookeeperRefresherHandler extends AbstractCoreThreadPoolDynamicRefr
                 loadNode(nodePath);
             } else if (newState == ConnectionState.RECONNECTED) {
                 loadNode(nodePath);
-            }};
+            }
+        };
 
         final CuratorListener curatorListener = (client, curatorEvent) -> {
             final WatchedEvent watchedEvent = curatorEvent.getWatchedEvent();
@@ -58,7 +57,9 @@ public class ZookeeperRefresherHandler extends AbstractCoreThreadPoolDynamicRefr
                     default:
                         break;
                 }
-            }};
+            }
+        };
+
         curatorFramework.getConnectionStateListenable().addListener(connectionStateListener);
         curatorFramework.getCuratorListenable().addListener(curatorListener);
         curatorFramework.start();
@@ -66,6 +67,7 @@ public class ZookeeperRefresherHandler extends AbstractCoreThreadPoolDynamicRefr
 
     /**
      * load config info and refresh.
+     *
      * @param nodePath zk config node path.
      */
     public void loadNode(String nodePath) {
@@ -83,13 +85,15 @@ public class ZookeeperRefresherHandler extends AbstractCoreThreadPoolDynamicRefr
                 } catch (Exception e) {
                     e.printStackTrace();
                 }
-                final Pair<String, String> keyValue = new ImmutablePair<>(nodeName, value);
+
-                content.append(keyValue.getKey()).append("=").append(keyValue.getValue()).append("\n");
+                content.append(nodeName).append("=").append(value).append("\n");
             });
+
             dynamicRefresh(content.toString());
             registerNotifyAlarmManage();
         } catch (Exception e) {
             log.error("load zk node error, nodePath is {}", nodePath, e);
         }
     }
+
 }

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/support/DynamicThreadPoolPostProcessor.java

@@ -152,6 +152,7 @@ public final class DynamicThreadPoolPostProcessor implements BeanPostProcessor {
 
             dynamicThreadPoolWrap.setExecutor(newDynamicPoolExecutor);
         }
+
         GlobalThreadPoolManage.registerPool(dynamicThreadPoolWrap.getTpId(), dynamicThreadPoolWrap);
         GlobalCoreThreadPoolManage.register(
                 threadPoolId,