Remove useless modules and refactor code

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterBeanContainer.java

@@ -29,7 +29,7 @@ import java.util.concurrent.ConcurrentHashMap;
 public class ThreadPoolAdapterBeanContainer implements InitializingBean {
 
     /**
-     * Store three-party thread pool framework bean instances.
+     * Store three-party thread pool framework bean instances
      */
     public static final Map<String, ThreadPoolAdapter> THREAD_POOL_ADAPTER_BEAN_CONTAINER = new ConcurrentHashMap<>();
 

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterRegisterAction.java

@@ -28,7 +28,7 @@ public interface ThreadPoolAdapterRegisterAction {
     /**
      * Get thread pool adapter cache configs.
      *
-     * @param threadPoolAdapterMap
+     * @param threadPoolAdapterMap thread-pool adapter map
      * @return List<ThreadPoolAdapterCacheConfig>
      */
     List<ThreadPoolAdapterCacheConfig> getThreadPoolAdapterCacheConfigs(Map<String, ThreadPoolAdapter> threadPoolAdapterMap);
@@ -36,8 +36,7 @@ public interface ThreadPoolAdapterRegisterAction {
     /**
      * Do register.
      *
-     * @param cacheConfigList
+     * @param cacheConfigList cache config list
-     * @return
      */
     void doRegister(List<ThreadPoolAdapterCacheConfig> cacheConfigList);
 }

hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/ThreadPoolAdapterScheduler.java

@@ -18,6 +18,7 @@
 package cn.hippo4j.adapter.hystrix;
 
 import cn.hippo4j.common.design.builder.ThreadFactoryBuilder;
+import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.ScheduledExecutorService;
@@ -31,6 +32,7 @@ public class ThreadPoolAdapterScheduler {
 
     private static final int TASK_INTERVAL_SECONDS = 10;
 
+    @Getter
     private final ScheduledExecutorService scheduler;
 
     public ThreadPoolAdapterScheduler() {
@@ -41,10 +43,11 @@ public class ThreadPoolAdapterScheduler {
                         .build());
     }
 
-    public ScheduledExecutorService getScheduler() {
+    /**
-        return scheduler;
+     * Gt task interval seconds.
-    }
+     *
-
+     * @return task interval seconds
+     */
     public int getTaskIntervalSeconds() {
         return TASK_INTERVAL_SECONDS;
     }

hippo4j-adapter/hippo4j-adapter-kafka/pom.xml

@@ -1,18 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <parent>
-        <groupId>cn.hippo4j</groupId>
-        <artifactId>hippo4j-adapter</artifactId>
-        <version>${revision}</version>
-    </parent>
-    <artifactId>hippo4j-adapter-kafka</artifactId>
-
-    <dependencies>
-        <dependency>
-            <groupId>cn.hippo4j</groupId>
-            <artifactId>hippo4j-adapter-base</artifactId>
-        </dependency>
-    </dependencies>
-</project>

hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java

@@ -1,52 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package cn.hippo4j.adapter.kafka;
-
-import cn.hippo4j.adapter.base.ThreadPoolAdapter;
-import cn.hippo4j.adapter.base.ThreadPoolAdapterParameter;
-import cn.hippo4j.adapter.base.ThreadPoolAdapterState;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.context.event.ApplicationStartedEvent;
-import org.springframework.context.ApplicationListener;
-
-/**
- * Kafka thread-pool adapter.
- */
-@Slf4j
-public class KafkaThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener<ApplicationStartedEvent> {
-
-    @Override
-    public String mark() {
-        return "Kafka";
-    }
-
-    @Override
-    public ThreadPoolAdapterState getThreadPoolState(String identify) {
-        return null;
-    }
-
-    @Override
-    public boolean updateThreadPool(ThreadPoolAdapterParameter threadPoolAdapterParameter) {
-        return false;
-    }
-
-    @Override
-    public void onApplicationEvent(ApplicationStartedEvent event) {
-
-    }
-}

hippo4j-adapter/hippo4j-adapter-rabbitmq/src/main/java/cn/hippo4j/adapter/rabbitmq/RabbitMQThreadPoolAdapter.java

@@ -105,7 +105,6 @@ public class RabbitMQThreadPoolAdapter implements ThreadPoolAdapter, Application
                     log.warn("Custom thread pools only support ThreadPoolExecutor");
                 }
             }
-
         });
     }
 }

hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/pom.xml

@@ -1,18 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <parent>
-        <groupId>cn.hippo4j</groupId>
-        <artifactId>hippo4j-adapter</artifactId>
-        <version>${revision}</version>
-    </parent>
-    <artifactId>hippo4j-adapter-spring-cloud-stream-kafka</artifactId>
-
-    <dependencies>
-        <dependency>
-            <groupId>cn.hippo4j</groupId>
-            <artifactId>hippo4j-adapter-base</artifactId>
-        </dependency>
-    </dependencies>
-</project>

hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaThreadPoolAdapter.java

@@ -1,59 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package cn.hippo4j.adapter.springcloud.stream.kafka;
-
-import cn.hippo4j.adapter.base.ThreadPoolAdapter;
-import cn.hippo4j.adapter.base.ThreadPoolAdapterParameter;
-import cn.hippo4j.adapter.base.ThreadPoolAdapterState;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.context.event.ApplicationStartedEvent;
-import org.springframework.context.ApplicationListener;
-
-import java.util.List;
-
-/**
- * Spring cloud stream kafka thread-pool adapter.
- */
-@Slf4j
-public class SpringCloudStreamKafkaThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener<ApplicationStartedEvent> {
-
-    @Override
-    public String mark() {
-        return "KafkaSpringCloudStream";
-    }
-
-    @Override
-    public ThreadPoolAdapterState getThreadPoolState(String identify) {
-        return null;
-    }
-
-    @Override
-    public List<ThreadPoolAdapterState> getThreadPoolStates() {
-        return null;
-    }
-
-    @Override
-    public boolean updateThreadPool(ThreadPoolAdapterParameter threadPoolAdapterParameter) {
-        return false;
-    }
-
-    @Override
-    public void onApplicationEvent(ApplicationStartedEvent event) {
-
-    }
-}

hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rabbitmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rabbitmq/SpringCloudStreamRabbitMQThreadPoolAdapter.java

@@ -39,7 +39,7 @@ import java.util.*;
 import static cn.hippo4j.common.constant.ChangeThreadPoolConstants.CHANGE_DELIMITER;
 
 /**
- * Spring cloud stream rabbimq thread-pool adapter.
+ * Spring cloud stream rabbit-mq thread-pool adapter.
  */
 @Slf4j
 public class SpringCloudStreamRabbitMQThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener<ApplicationStartedEvent> {

hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/AbstractWebThreadPoolService.java

@@ -34,12 +34,12 @@ import java.util.concurrent.Executor;
 public abstract class AbstractWebThreadPoolService implements WebThreadPoolService, ApplicationRunner {
 
     /**
-     * Thread pool executor.
+     * Thread pool executor
      */
     protected volatile Executor executor;
 
     /**
-     * Get web thread pool by server.
+     * Get web thread pool by server
      *
      * @param webServer
      * @return

hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolHandlerChoose.java

@@ -30,7 +30,7 @@ public class WebThreadPoolHandlerChoose {
     /**
      * Choose the web thread pool service bean.
      *
-     * @return
+     * @return web thread pool service bean
      */
     public WebThreadPoolService choose() {
         WebThreadPoolService webThreadPoolService;

hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolRunStateHandler.java

@@ -35,9 +35,9 @@ public class WebThreadPoolRunStateHandler extends AbstractThreadPoolRuntime {
         long used = MemoryUtil.heapMemoryUsed();
         long max = MemoryUtil.heapMemoryMax();
         String memoryProportion = StringUtil.newBuilder(
-                "已分配: ",
+                "Allocation: ",
                 ByteConvertUtil.getPrintSize(used),
-                " / 最大可用: ",
+                " / Maximum available: ",
                 ByteConvertUtil.getPrintSize(max));
         poolRunStateInfo.setCurrentLoad(poolRunStateInfo.getCurrentLoad() + "%");
         poolRunStateInfo.setPeakLoad(poolRunStateInfo.getPeakLoad() + "%");

hippo4j-adapter/pom.xml

@@ -14,12 +14,10 @@
         <module>hippo4j-adapter-base</module>
         <module>hippo4j-adapter-dubbo</module>
         <module>hippo4j-adapter-alibaba-dubbo</module>
-        <module>hippo4j-adapter-kafka</module>
         <module>hippo4j-adapter-rabbitmq</module>
         <module>hippo4j-adapter-rocketmq</module>
         <module>hippo4j-adapter-hystrix</module>
         <module>hippo4j-adapter-spring-cloud-stream-rocketmq</module>
-        <module>hippo4j-adapter-spring-cloud-stream-kafka</module>
         <module>hippo4j-adapter-spring-cloud-stream-rabbitmq</module>
         <module>hippo4j-adapter-web</module>
     </modules>