From 34f394a0c59892c64fabc265e8e255097c83ea95 Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Sun, 5 Sep 2021 22:16:23 +0800 Subject: [PATCH] Optimize the comments and logs of the dynamic starter module. --- .../starter/common/CommonThreadPool.java | 2 +- .../starter/config/BootstrapProperties.java | 2 +- .../starter/config/DiscoveryConfig.java | 2 +- .../DynamicThreadPoolAutoConfiguration.java | 2 +- .../starter/config/HttpClientConfig.java | 2 +- .../starter/config/MessageAlarmConfig.java | 2 +- .../controller/PoolRunStateController.java | 2 +- .../threadpool/starter/core/CacheData.java | 2 +- .../threadpool/starter/core/ClientWorker.java | 2 +- .../threadpool/starter/core/ConfigAdapter.java | 4 ++-- .../threadpool/starter/core/ConfigService.java | 6 +++--- .../threadpool/starter/core/DiscoveryClient.java | 2 +- .../starter/core/DynamicThreadPoolClient.java | 2 +- .../core/DynamicThreadPoolPostProcessor.java | 2 +- .../starter/core/GlobalThreadPoolManage.java | 2 +- .../threadpool/starter/core/Listener.java | 4 ++-- .../starter/core/ThreadPoolConfigService.java | 2 +- .../starter/core/ThreadPoolDynamicRefresh.java | 2 +- .../starter/core/ThreadPoolOperation.java | 2 +- .../core/ThreadPoolSubscribeCallback.java | 4 ++-- .../starter/enable/EnableDynamicThreadPool.java | 2 +- .../starter/enable/MarkerConfiguration.java | 2 +- .../handler/DynamicThreadPoolBannerHandler.java | 2 +- .../handler/ThreadPoolRunStateHandler.java | 8 ++++---- .../threadpool/starter/remote/HttpAgent.java | 16 ++++++++-------- .../starter/remote/ServerHttpAgent.java | 2 +- .../starter/remote/ServerListManager.java | 6 +++--- .../starter/spi/CustomBlockingQueue.java | 2 +- .../spi/CustomRejectedExecutionHandler.java | 2 +- .../starter/spi/DynamicTpServiceLoader.java | 2 +- .../threadpool/starter/toolkit/ArrayUtil.java | 2 +- .../starter/toolkit/CalculateUtil.java | 2 +- .../starter/toolkit/CloudCommonIdUtil.java | 2 +- .../starter/toolkit/HttpClientUtil.java | 2 +- .../thread/AbstractBuildThreadPoolTemplate.java | 2 +- .../starter/toolkit/thread/Builder.java | 4 ++-- .../toolkit/thread/CustomThreadPoolExecutor.java | 2 +- .../toolkit/thread/FastThreadPoolExecutor.java | 2 +- .../starter/toolkit/thread/QueueTypeEnum.java | 2 +- .../starter/toolkit/thread/RejectedPolicies.java | 2 +- .../ResizableCapacityLinkedBlockIngQueue.java | 2 +- .../starter/toolkit/thread/TaskQueue.java | 2 +- .../toolkit/thread/ThreadFactoryBuilder.java | 2 +- .../toolkit/thread/ThreadPoolBuilder.java | 2 +- .../thread/ThreadPoolExecutorTemplate.java | 2 +- .../starter/wrap/DynamicThreadPoolWrap.java | 2 +- .../starter/wrap/ManagerListenerWrap.java | 2 +- 47 files changed, 65 insertions(+), 65 deletions(-) diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/common/CommonThreadPool.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/common/CommonThreadPool.java index 4d01a2b2..76a80e34 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/common/CommonThreadPool.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/common/CommonThreadPool.java @@ -8,7 +8,7 @@ import com.github.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder; import java.util.concurrent.TimeUnit; /** - * Common ThreadPool. + * Common threadPool. * * @author chen.ma * @date 2021/6/16 22:35 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/BootstrapProperties.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/BootstrapProperties.java index 4b418a92..142a40c5 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/BootstrapProperties.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/BootstrapProperties.java @@ -9,7 +9,7 @@ import org.springframework.boot.context.properties.ConfigurationProperties; import java.util.List; /** - * Bootstrap Properties. + * Bootstrap properties. * * @author chen.ma * @date 2021/6/22 09:14 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DiscoveryConfig.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DiscoveryConfig.java index 572df75f..99c479bf 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DiscoveryConfig.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DiscoveryConfig.java @@ -14,7 +14,7 @@ import static com.github.dynamic.threadpool.starter.toolkit.CloudCommonIdUtil.ge import static com.github.dynamic.threadpool.starter.toolkit.CloudCommonIdUtil.getIpApplicationName; /** - * Dynamic Tp Discovery Config. + * Dynamic threadPool discovery config. * * @author chen.ma * @date 2021/8/6 21:35 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DynamicThreadPoolAutoConfiguration.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DynamicThreadPoolAutoConfiguration.java index 6868168b..edc46b7f 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DynamicThreadPoolAutoConfiguration.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DynamicThreadPoolAutoConfiguration.java @@ -19,7 +19,7 @@ import org.springframework.core.Ordered; import org.springframework.core.annotation.Order; /** - * DynamicTp Auto Configuration. + * DynamicTp auto configuration. * * @author chen.ma * @date 2021/6/22 09:20 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/HttpClientConfig.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/HttpClientConfig.java index 76096240..f41f3e29 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/HttpClientConfig.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/HttpClientConfig.java @@ -14,7 +14,7 @@ import javax.net.ssl.X509TrustManager; import java.util.concurrent.TimeUnit; /** - * Http Client Config. + * Http client config. * * @author chen.ma * @date 2021/6/10 13:28 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/MessageAlarmConfig.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/MessageAlarmConfig.java index 3d19b79a..fc828a38 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/MessageAlarmConfig.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/MessageAlarmConfig.java @@ -12,7 +12,7 @@ import org.springframework.context.annotation.DependsOn; import org.springframework.core.env.ConfigurableEnvironment; /** - * Message Alarm Config. + * Message alarm config. * * @author chen.ma * @date 2021/8/15 15:39 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/controller/PoolRunStateController.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/controller/PoolRunStateController.java index a5ec3750..bf5c1d7a 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/controller/PoolRunStateController.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/controller/PoolRunStateController.java @@ -9,7 +9,7 @@ import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; /** - * Pool Run State Controller. + * Pool run state controller. * * @author chen.ma * @date 2021/7/7 21:34 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/CacheData.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/CacheData.java index 394b3db4..4eb1e6b8 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/CacheData.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/CacheData.java @@ -9,7 +9,7 @@ import lombok.extern.slf4j.Slf4j; import java.util.concurrent.CopyOnWriteArrayList; /** - * Cache Data. + * Cache data. * * @author chen.ma * @date 2021/6/22 20:46 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ClientWorker.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ClientWorker.java index f62dd667..a895b819 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ClientWorker.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ClientWorker.java @@ -21,7 +21,7 @@ import java.util.concurrent.TimeUnit; import static com.github.dynamic.threadpool.common.constant.Constants.*; /** - * Client Worker. + * Client worker. * * @author chen.ma * @date 2021/6/20 18:34 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigAdapter.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigAdapter.java index e3f57ee2..965b9137 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigAdapter.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigAdapter.java @@ -1,7 +1,7 @@ package com.github.dynamic.threadpool.starter.core; /** - * Config Adapter. + * Config adapter. * * @author chen.ma * @date 2021/6/22 21:29 @@ -9,7 +9,7 @@ package com.github.dynamic.threadpool.starter.core; public class ConfigAdapter { /** - * callback Config. + * Callback Config. * * @param config */ diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigService.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigService.java index 588db35e..82d6b75c 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigService.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigService.java @@ -1,7 +1,7 @@ package com.github.dynamic.threadpool.starter.core; /** - * Config Service. + * Config service. * * @author chen.ma * @date 2021/6/21 21:49 @@ -9,7 +9,7 @@ package com.github.dynamic.threadpool.starter.core; public interface ConfigService { /** - * 添加监听器, 如果服务端发生变更, 客户端会使用监听器进行回调 + * Add listener. * * @param tenantId * @param itemId @@ -19,7 +19,7 @@ public interface ConfigService { void addListener(String tenantId, String itemId, String tpId, Listener listener); /** - * 获取服务状态 + * Get server status. * * @return */ diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DiscoveryClient.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DiscoveryClient.java index 5f55ee19..77f46683 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DiscoveryClient.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DiscoveryClient.java @@ -13,7 +13,7 @@ import lombok.extern.slf4j.Slf4j; import java.util.concurrent.*; /** - * Discovery Client. + * Discovery client. * * @author chen.ma * @date 2021/7/13 21:51 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolClient.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolClient.java index 84b2fde0..72675b26 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolClient.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolClient.java @@ -1,7 +1,7 @@ package com.github.dynamic.threadpool.starter.core; /** - * Dynamic Tp Client. + * Dynamic tp client. * * @author chen.ma * @date 2021/7/13 21:50 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolPostProcessor.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolPostProcessor.java index e02310b4..e007ccb9 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolPostProcessor.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolPostProcessor.java @@ -24,7 +24,7 @@ import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; /** - * Dynamic ThreadPool Post Processor. + * Dynamic threadPool post processor. * * @author chen.ma * @date 2021/8/2 20:40 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/GlobalThreadPoolManage.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/GlobalThreadPoolManage.java index 660a819d..9f3670ba 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/GlobalThreadPoolManage.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/GlobalThreadPoolManage.java @@ -7,7 +7,7 @@ import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** - * Global ThreadPool Manage. + * Global threadPool manage. * * @author chen.ma * @date 2021/6/20 15:57 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/Listener.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/Listener.java index 96e1e7c0..28c6c759 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/Listener.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/Listener.java @@ -11,14 +11,14 @@ import java.util.concurrent.Executor; public interface Listener { /** - * 获取执行器 + * Get executor. * * @return */ Executor getExecutor(); /** - * 接受配置信息 + * Receive config info. * * @param configInfo */ diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolConfigService.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolConfigService.java index 941158dc..1f840cad 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolConfigService.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolConfigService.java @@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.starter.remote.HttpAgent; import java.util.Arrays; /** - * ThreadPool Config Service. + * ThreadPool config service. * * @author chen.ma * @date 2021/6/21 21:50 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolDynamicRefresh.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolDynamicRefresh.java index b5872f1c..7fafb7fe 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolDynamicRefresh.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolDynamicRefresh.java @@ -13,7 +13,7 @@ import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; /** - * ThreadPool Dynamic Refresh. + * ThreadPool dynamic refresh. * * @author chen.ma * @date 2021/6/20 15:51 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolOperation.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolOperation.java index 78d1680e..7a98f10b 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolOperation.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolOperation.java @@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.starter.config.BootstrapProperties; import java.util.concurrent.Executor; /** - * ThreadPool Operation. + * ThreadPool operation. * * @author chen.ma * @date 2021/6/22 20:25 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolSubscribeCallback.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolSubscribeCallback.java index 476f42b3..1132040d 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolSubscribeCallback.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolSubscribeCallback.java @@ -1,7 +1,7 @@ package com.github.dynamic.threadpool.starter.core; /** - * ThreadPool Subscribe Callback. + * ThreadPool subscribe callback. * * @author chen.ma * @date 2021/6/22 20:26 @@ -9,7 +9,7 @@ package com.github.dynamic.threadpool.starter.core; public interface ThreadPoolSubscribeCallback { /** - * 回调函数 + * Callback. * * @param config */ diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/EnableDynamicThreadPool.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/EnableDynamicThreadPool.java index b339e163..fd717f06 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/EnableDynamicThreadPool.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/EnableDynamicThreadPool.java @@ -5,7 +5,7 @@ import org.springframework.context.annotation.Import; import java.lang.annotation.*; /** - * Annotation to activate Dynamic ThreadPool related configuration. + * Annotation to activate dynamic threadPool related configuration. * * @author chen.ma * @date 2021/7/8 23:28 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/MarkerConfiguration.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/MarkerConfiguration.java index 90aa2676..167071ac 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/MarkerConfiguration.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/MarkerConfiguration.java @@ -4,7 +4,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** - * 动态线程池标记配置类 + * Marker configuration. * * @author chen.ma * @date 2021/7/8 23:30 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/DynamicThreadPoolBannerHandler.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/DynamicThreadPoolBannerHandler.java index c5b23218..b444293b 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/DynamicThreadPoolBannerHandler.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/DynamicThreadPoolBannerHandler.java @@ -10,7 +10,7 @@ import org.springframework.boot.ansi.AnsiOutput; import org.springframework.boot.ansi.AnsiStyle; /** - * 动态线程池打印 Banner. + * Dynamic thread pool print banner. * * @author chen.ma * @date 2021/6/20 16:34 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/ThreadPoolRunStateHandler.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/ThreadPoolRunStateHandler.java index e3932c73..09637ffc 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/ThreadPoolRunStateHandler.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/ThreadPoolRunStateHandler.java @@ -13,7 +13,7 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.ThreadPoolExecutor; /** - * Thread Pool Run State Service. + * Thread pool run state service. * * @author chen.ma * @date 2021/7/12 21:25 @@ -21,11 +21,11 @@ import java.util.concurrent.ThreadPoolExecutor; @Slf4j public class ThreadPoolRunStateHandler { - private static InetAddress addr; + private static InetAddress INET_ADDRESS; static { try { - addr = InetAddress.getLocalHost(); + INET_ADDRESS = InetAddress.getLocalHost(); } catch (UnknownHostException ex) { log.error("Local IP acquisition failed.", ex); } @@ -75,7 +75,7 @@ public class ThreadPoolRunStateHandler { stateInfo.setQueueCapacity(queueCapacity); stateInfo.setLargestPoolSize(largestPoolSize); stateInfo.setCompletedTaskCount(completedTaskCount); - stateInfo.setHost(addr.getHostAddress()); + stateInfo.setHost(INET_ADDRESS.getHostAddress()); stateInfo.setTpId(tpId); int rejectCount = pool instanceof CustomThreadPoolExecutor diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/HttpAgent.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/HttpAgent.java index faf64cb4..e9470ab4 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/HttpAgent.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/HttpAgent.java @@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.common.web.base.Result; import java.util.Map; /** - * Http Agent. + * Http agent. * * @author chen.ma * @date 2021/6/23 20:45 @@ -13,26 +13,26 @@ import java.util.Map; public interface HttpAgent { /** - * 开始获取服务集合 + * Start. */ void start(); /** - * 获取命名空间 + * Get tenant id. * * @return */ String getTenantId(); /** - * 获取编码集 + * Get encode. * * @return */ String getEncode(); /** - * 发起 Http Post 请求 By Discovery + * Send HTTP post request by discovery. * * @param path * @param body @@ -41,7 +41,7 @@ public interface HttpAgent { Result httpPostByDiscovery(String path, Object body); /** - * 发起 Http Get 请求 By 动态配置 + * Send HTTP get request by dynamic config. * * @param path * @param headers @@ -53,7 +53,7 @@ public interface HttpAgent { long readTimeoutMs); /** - * 发起 Http Post 请求 By 动态配置 + * Send HTTP post request by dynamic config. * * @param path * @param headers @@ -65,7 +65,7 @@ public interface HttpAgent { long readTimeoutMs); /** - * 发起 Http Delete 请求 By 动态配置 + * Send HTTP delete request by dynamic config. * * @param path * @param headers diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerHttpAgent.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerHttpAgent.java index 07ce80f7..1adf2021 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerHttpAgent.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerHttpAgent.java @@ -7,7 +7,7 @@ import com.github.dynamic.threadpool.starter.toolkit.HttpClientUtil; import java.util.Map; /** - * Server Http Agent. + * Server http agent. * * @author chen.ma * @date 2021/6/23 20:50 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerListManager.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerListManager.java index acae5cad..d8ccecd9 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerListManager.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerListManager.java @@ -7,7 +7,7 @@ import org.springframework.util.StringUtils; import java.util.*; /** - * Server List Manager. + * Server list manager. * * @author chen.ma * @date 2021/6/23 20:42 @@ -39,7 +39,7 @@ public class ServerListManager { for (String serverAddr : serverAddrsArr) { if (serverAddr.startsWith(HTTPS) || serverAddr.startsWith(HTTP)) { - // TODO 固定写,后面优化 + // TODO Temporarily fixed write, later optimized currentServerAddr = serverAddr; serverAddrs.add(serverAddr); } @@ -71,7 +71,7 @@ public class ServerListManager { final Iterator iter; public ServerAddressIterator(List source) { - sorted = new ArrayList(); + sorted = new ArrayList(); for (String address : source) { sorted.add(new RandomizedServerAddress(address)); } diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomBlockingQueue.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomBlockingQueue.java index e6bfe570..9834df3a 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomBlockingQueue.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomBlockingQueue.java @@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.spi; import java.util.concurrent.BlockingQueue; /** - * Custom BlockingQueue. + * Custom blockingQueue. * * @author chen.ma * @date 2021/7/11 00:51 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomRejectedExecutionHandler.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomRejectedExecutionHandler.java index b6ef8e7d..653e5640 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomRejectedExecutionHandler.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomRejectedExecutionHandler.java @@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.spi; import java.util.concurrent.RejectedExecutionHandler; /** - * Custom RejectedExecution Handler. + * Custom rejectedExecution handler. * * @author chen.ma * @date 2021/7/10 23:51 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/DynamicTpServiceLoader.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/DynamicTpServiceLoader.java index aa8f5d46..7a138e38 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/DynamicTpServiceLoader.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/DynamicTpServiceLoader.java @@ -5,7 +5,7 @@ import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; /** - * Dynamic ThreadPool Service Loader. + * Dynamic threadPool service loader. * * @author chen.ma * @date 2021/7/10 23:45 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/ArrayUtil.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/ArrayUtil.java index b8e7aa82..f0d8e002 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/ArrayUtil.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/ArrayUtil.java @@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.toolkit; import java.lang.reflect.Array; /** - * Array Util. + * Array util. * * @author chen.ma * @date 2021/7/5 21:54 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CalculateUtil.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CalculateUtil.java index 19f21869..290eccdf 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CalculateUtil.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CalculateUtil.java @@ -1,7 +1,7 @@ package com.github.dynamic.threadpool.starter.toolkit; /** - * Calculate Util. + * Calculate util. * * @author chen.ma * @date 2021/8/15 14:29 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CloudCommonIdUtil.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CloudCommonIdUtil.java index fb037de4..23e42d9a 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CloudCommonIdUtil.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/CloudCommonIdUtil.java @@ -6,7 +6,7 @@ import org.springframework.core.env.PropertyResolver; import java.net.InetAddress; /** - * Cloud Common Id Util. + * Cloud common id util. * * @author chen.ma * @date 2021/8/6 21:02 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/HttpClientUtil.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/HttpClientUtil.java index b728889b..def09a01 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/HttpClientUtil.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/HttpClientUtil.java @@ -11,7 +11,7 @@ import java.util.Map; import java.util.concurrent.TimeUnit; /** - * HttpClient Util. + * HttpClient util. * * @author chen.ma * @date 2021/6/10 13:30 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java index 1a43740f..38a775ff 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java @@ -10,7 +10,7 @@ import java.util.concurrent.*; import java.util.concurrent.locks.AbstractQueuedSynchronizer; /** - * Abstract Build ThreadPool Template. + * Abstract build threadPool template. * * @author chen.ma * @date 2021/7/5 21:45 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/Builder.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/Builder.java index 37d30dae..6f78b19e 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/Builder.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/Builder.java @@ -11,9 +11,9 @@ import java.io.Serializable; public interface Builder extends Serializable { /** - * 构建 + * Build. * - * @return 被构建的对象 + * @return */ T build(); diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/CustomThreadPoolExecutor.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/CustomThreadPoolExecutor.java index 9d970411..a770c361 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/CustomThreadPoolExecutor.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/CustomThreadPoolExecutor.java @@ -18,7 +18,7 @@ import java.util.concurrent.locks.ReentrantLock; import static com.github.dynamic.threadpool.common.constant.Constants.MAP_INITIAL_CAPACITY; /** - * Custom Thread Pool Wrap. + * Custom threadPool wrap. * * @author chen.ma * @date 2021/7/8 21:47 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/FastThreadPoolExecutor.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/FastThreadPoolExecutor.java index fc086a9b..f99b7ccb 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/FastThreadPoolExecutor.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/FastThreadPoolExecutor.java @@ -9,7 +9,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; /** - * Fast ThreadPool Executor. + * Fast threadPool executor. * * @author chen.ma * @date 2021/7/5 21:00 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/QueueTypeEnum.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/QueueTypeEnum.java index 067d3cb9..4f4fda0e 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/QueueTypeEnum.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/QueueTypeEnum.java @@ -10,7 +10,7 @@ import java.util.Optional; import java.util.concurrent.*; /** - * Queue Type Enum. + * Queue type enum. * * @author chen.ma * @date 2021/6/25 12:30 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/RejectedPolicies.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/RejectedPolicies.java index 1f4e3f16..48fd868c 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/RejectedPolicies.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/RejectedPolicies.java @@ -6,7 +6,7 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.RejectedExecutionHandler; /** - * Rejected Policies. + * Rejected policies. * * @author chen.ma * @date 2021/7/5 21:23 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ResizableCapacityLinkedBlockIngQueue.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ResizableCapacityLinkedBlockIngQueue.java index 1f5eee88..b9ec3e1e 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ResizableCapacityLinkedBlockIngQueue.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ResizableCapacityLinkedBlockIngQueue.java @@ -6,7 +6,7 @@ import lombok.extern.slf4j.Slf4j; import java.util.concurrent.LinkedBlockingQueue; /** - * Resizable Capacity LinkedBlockIngQueue. + * Resizable capacity linkedBlockIngQueue. * * @author chen.ma * @date 2021/6/20 14:24 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/TaskQueue.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/TaskQueue.java index ef8d1a0a..16391ca2 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/TaskQueue.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/TaskQueue.java @@ -5,7 +5,7 @@ import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.TimeUnit; /** - * Task Queue. + * Task queue. * * @author chen.ma * @date 2021/7/5 21:00 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadFactoryBuilder.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadFactoryBuilder.java index 5a3247c7..b0265639 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadFactoryBuilder.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadFactoryBuilder.java @@ -5,7 +5,7 @@ import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicLong; /** - * ThreadFactory Builder. + * ThreadFactory builder. * * @author chen.ma * @date 2021/7/5 21:53 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java index 09e38cb4..775daca6 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java @@ -8,7 +8,7 @@ import java.math.BigDecimal; import java.util.concurrent.*; /** - * ThreadPool Builder. + * ThreadPool builder. * * @author chen.ma * @date 2021/6/28 17:29 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolExecutorTemplate.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolExecutorTemplate.java index 2917fe45..3d07c27a 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolExecutorTemplate.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolExecutorTemplate.java @@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.starter.toolkit.ArrayUtil; import java.util.concurrent.*; /** - * ThreadPool Executor Template. + * ThreadPool executor template. * * @author chen.ma * @date 2021/7/5 21:59 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/DynamicThreadPoolWrap.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/DynamicThreadPoolWrap.java index 2df3b945..a0c2cfb6 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/DynamicThreadPoolWrap.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/DynamicThreadPoolWrap.java @@ -8,7 +8,7 @@ import java.util.concurrent.Callable; import java.util.concurrent.Future; /** - * Dynamic ThreadPool Wrap. + * Dynamic threadPool wrap. * * @author chen.ma * @date 2021/6/20 16:55 diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/ManagerListenerWrap.java b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/ManagerListenerWrap.java index c0240a7a..2b35b07d 100644 --- a/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/ManagerListenerWrap.java +++ b/dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/ManagerListenerWrap.java @@ -5,7 +5,7 @@ import lombok.Getter; import lombok.Setter; /** - * Manager Listener Wrap. + * Manager listener wrap. * * @author chen.ma * @date 2021/6/22 17:47