msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

Optimize class naming and code format.

Browse Source
pull/161/head
chen.ma 3 years ago
parent f4613c250c
commit e983389faf
43 changed files with 118 additions and 147 deletions
Show Stats Download Patch File Download Diff File

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/common/CommonThreadPool.java
Unescape View File

@ -8,7 +8,7 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* 公共线程池生产者
* Common ThreadPool.
*
* @author chen.ma
* @date 2021/6/16 22:35

15
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DynamicThreadPoolProperties.java → dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/BootstrapProperties.java
Unescape View File

@ -6,7 +6,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.properties.ConfigurationProperties;
/**
* 动态线程池配置
* Bootstrap Properties.
*
* @author chen.ma
* @date 2021/6/22 09:14
@ -14,28 +14,29 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
@Slf4j
@Getter
@Setter
@ConfigurationProperties(prefix = DynamicThreadPoolProperties.PREFIX)
public class DynamicThreadPoolProperties {
@ConfigurationProperties(prefix = BootstrapProperties.PREFIX)
public class BootstrapProperties {
public static final String PREFIX = "spring.dynamic.thread-pool";
/**
* 服务地址
* serverAddr
*/
private String serverAddr;
/**
* 租户 ID
* namespace
*/
private String namespace;
/**
* 项目 ID
* itemId
*/
private String itemId;
/**
* 是否开启 banner
* Enable banner
*/
private boolean banner = true;
}

28
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/DynamicThreadPoolAutoConfiguration.java
Unescape View File

@ -3,14 +3,13 @@ package com.github.dynamic.threadpool.starter.config;
import com.github.dynamic.threadpool.common.config.ApplicationContextHolder;
import com.github.dynamic.threadpool.starter.controller.PoolRunStateController;
import com.github.dynamic.threadpool.starter.core.ConfigService;
import com.github.dynamic.threadpool.starter.core.ThreadPoolBeanPostProcessor;
import com.github.dynamic.threadpool.starter.core.DynamicThreadPoolPostProcessor;
import com.github.dynamic.threadpool.starter.core.ThreadPoolConfigService;
import com.github.dynamic.threadpool.starter.core.ThreadPoolOperation;
import com.github.dynamic.threadpool.starter.enable.DynamicThreadPoolMarkerConfiguration;
import com.github.dynamic.threadpool.starter.handler.ThreadPoolBannerHandler;
import com.github.dynamic.threadpool.starter.enable.MarkerConfiguration;
import com.github.dynamic.threadpool.starter.handler.DynamicThreadPoolBannerHandler;
import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
@ -18,24 +17,23 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* 动态线程池自动装配类
* DynamicTp Auto Configuration.
*
* @author chen.ma
* @date 2021/6/22 09:20
*/
@Slf4j
@Configuration
@AllArgsConstructor
@ImportAutoConfiguration(HttpClientConfig.class)
@EnableConfigurationProperties(DynamicThreadPoolProperties.class)
@ConditionalOnBean(DynamicThreadPoolMarkerConfiguration.Marker.class)
@EnableConfigurationProperties(BootstrapProperties.class)
@ConditionalOnBean(MarkerConfiguration.Marker.class)
@ImportAutoConfiguration({HttpClientConfig.class, DiscoveryConfig.class})
public class DynamicThreadPoolAutoConfiguration {
private final DynamicThreadPoolProperties properties;
private final BootstrapProperties properties;
@Bean
public ThreadPoolBannerHandler threadPoolBannerHandler() {
return new ThreadPoolBannerHandler(properties);
public DynamicThreadPoolBannerHandler threadPoolBannerHandler() {
return new DynamicThreadPoolBannerHandler(properties);
}
@Bean
@ -56,8 +54,8 @@ public class DynamicThreadPoolAutoConfiguration {
@Bean
@SuppressWarnings("all")
public ThreadPoolBeanPostProcessor threadPoolBeanPostProcessor(HttpAgent httpAgent, ThreadPoolOperation threadPoolOperation) {
return new ThreadPoolBeanPostProcessor(properties, httpAgent, threadPoolOperation);
public DynamicThreadPoolPostProcessor threadPoolBeanPostProcessor(HttpAgent httpAgent, ThreadPoolOperation threadPoolOperation) {
return new DynamicThreadPoolPostProcessor(properties, httpAgent, threadPoolOperation);
}
@Bean
@ -66,3 +64,5 @@ public class DynamicThreadPoolAutoConfiguration {
}
}

14
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/config/HttpClientConfig.java
Unescape View File

@ -4,7 +4,6 @@ import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import com.github.dynamic.threadpool.starter.remote.ServerHttpAgent;
import com.github.dynamic.threadpool.starter.toolkit.HttpClientUtil;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import org.springframework.context.annotation.Bean;
@ -20,14 +19,8 @@ import java.util.concurrent.TimeUnit;
* @author chen.ma
* @date 2021/6/10 13:28
*/
@Slf4j
public class HttpClientConfig {
/**
* 配置 OkHttpClient Bean
*
* @return
*/
@Bean
public OkHttpClient okHttpClient() {
OkHttpClient.Builder build = new OkHttpClient.Builder();
@ -44,15 +37,10 @@ public class HttpClientConfig {
}
@Bean
public HttpAgent httpAgent(DynamicThreadPoolProperties properties, HttpClientUtil httpClientUtil) {
public HttpAgent httpAgent(BootstrapProperties properties, HttpClientUtil httpClientUtil) {
return new ServerHttpAgent(properties, httpClientUtil);
}
/**
* 支持 Https
*
* @param builder
*/
@SneakyThrows
private void supportHttps(OkHttpClient.Builder builder) {
final TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() {

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/controller/PoolRunStateController.java
Unescape View File

@ -22,4 +22,5 @@ public class PoolRunStateController {
PoolRunStateInfo poolRunState = ThreadPoolRunStateHandler.getPoolRunState(tpId);
return Results.success(poolRunState);
}
}

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/CacheData.java
Unescape View File

@ -91,4 +91,5 @@ public class CacheData {
public void setTaskId(Integer taskId) {
this.taskId = taskId;
}
}

52
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ClientWorker.java
Unescape View File

@ -25,7 +25,7 @@ import static com.github.dynamic.threadpool.common.constant.Constants.LINE_SEPAR
import static com.github.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR;
/**
* 客户端监听
* Client Worker.
*
* @author chen.ma
* @date 2021/6/20 18:34
@ -76,9 +76,6 @@ public class ClientWorker {
}, 1L, 10L, TimeUnit.MILLISECONDS);
}
/**
* 检查配置信息
*/
public void checkConfigInfo() {
int listenerSize = cacheMap.size();
double perTaskConfigSize = 3000D;
@ -92,9 +89,6 @@ public class ClientWorker {
}
}
/**
* 长轮训任务
*/
class LongPollingRunnable implements Runnable {
@SneakyThrows
@ -151,12 +145,6 @@ public class ClientWorker {
}
}
/**
* 转换入参
*
* @param cacheDataList
* @return
*/
private List<String> checkUpdateDataIds(List<CacheData> cacheDataList) {
StringBuilder sb = new StringBuilder();
for (CacheData cacheData : cacheDataList) {
@ -169,12 +157,6 @@ public class ClientWorker {
return checkUpdateTpIds(sb.toString());
}
/**
* 检查修改的线程池 ID
*
* @param probeUpdateString
* @return
*/
public List<String> checkUpdateTpIds(String probeUpdateString) {
Map<String, String> params = new HashMap(2);
params.put(Constants.PROBE_MODIFY_REQUEST, probeUpdateString);
@ -204,15 +186,6 @@ public class ClientWorker {
return Collections.emptyList();
}
/**
* 获取服务端配置
*
* @param namespace
* @param itemId
* @param tpId
* @param readTimeout
* @return
*/
public String getServerConfig(String namespace, String itemId, String tpId, long readTimeout) {
Map<String, String> params = new HashMap(3);
params.put("namespace", namespace);
@ -229,12 +202,6 @@ public class ClientWorker {
return Constants.NULL;
}
/**
* Http 响应中获取变更的配置项
*
* @param response
* @return
*/
public List<String> parseUpdateDataIdResponse(String response) {
if (StringUtils.isEmpty(response)) {
return Collections.emptyList();
@ -268,14 +235,6 @@ public class ClientWorker {
return updateList;
}
/**
* CacheData 添加 Listener
*
* @param namespace
* @param itemId
* @param tpId
* @param listeners
*/
public void addTenantListeners(String namespace, String itemId, String tpId, List<? extends Listener> listeners) {
CacheData cacheData = addCacheDataIfAbsent(namespace, itemId, tpId);
for (Listener listener : listeners) {
@ -283,14 +242,6 @@ public class ClientWorker {
}
}
/**
* CacheData 不存在则添加
*
* @param namespace
* @param itemId
* @param tpId
* @return
*/
public CacheData addCacheDataIfAbsent(String namespace, String itemId, String tpId) {
CacheData cacheData = cacheMap.get(tpId);
if (cacheData != null) {
@ -325,4 +276,5 @@ public class ClientWorker {
private void setHealthServer(boolean isHealthServer) {
this.isHealthServer = isHealthServer;
}
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigAdapter.java
Unescape View File

@ -9,11 +9,12 @@ package com.github.dynamic.threadpool.starter.core;
public class ConfigAdapter {
/**
* 回调修改线程池配置
* callback Config.
*
* @param config
*/
public void callbackConfig(String config) {
ThreadPoolDynamicRefresh.refreshDynamicPool(config);
}
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ConfigService.java
Unescape View File

@ -1,7 +1,7 @@
package com.github.dynamic.threadpool.starter.core;
/**
* 配置服务
* Config Service.
*
* @author chen.ma
* @date 2021/6/21 21:49
@ -24,4 +24,5 @@ public interface ConfigService {
* @return
*/
String getServerStatus();
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicTpClient.java → dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolClient.java
Unescape View File

@ -6,5 +6,5 @@ package com.github.dynamic.threadpool.starter.core;
* @author chen.ma
* @date 2021/7/13 21:50
*/
public interface DynamicTpClient {
public interface DynamicThreadPoolClient {
}

10
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolBeanPostProcessor.java → dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/DynamicThreadPoolPostProcessor.java
Unescape View File

@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.common.constant.Constants;
import com.github.dynamic.threadpool.common.model.PoolParameterInfo;
import com.github.dynamic.threadpool.common.web.base.Result;
import com.github.dynamic.threadpool.starter.common.CommonThreadPool;
import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import com.github.dynamic.threadpool.starter.config.BootstrapProperties;
import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import com.github.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import com.github.dynamic.threadpool.starter.toolkit.thread.RejectedTypeEnum;
@ -23,21 +23,21 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* 线程池包装后置处理器
* Dynamic ThreadPool Post Processor.
*
* @author chen.ma
* @date 2021/8/2 20:40
*/
@Slf4j
public final class ThreadPoolBeanPostProcessor implements BeanPostProcessor {
public final class DynamicThreadPoolPostProcessor implements BeanPostProcessor {
private final DynamicThreadPoolProperties properties;
private final BootstrapProperties properties;
private final ThreadPoolOperation threadPoolOperation;
private final HttpAgent httpAgent;
public ThreadPoolBeanPostProcessor(DynamicThreadPoolProperties properties, HttpAgent httpAgent,
public DynamicThreadPoolPostProcessor(BootstrapProperties properties, HttpAgent httpAgent,
ThreadPoolOperation threadPoolOperation) {
this.properties = properties;
this.httpAgent = httpAgent;

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/GlobalThreadPoolManage.java
Unescape View File

@ -7,7 +7,7 @@ import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* 线程池全局管理
* Global ThreadPool Manage.
*
* @author chen.ma
* @date 2021/6/20 15:57
@ -38,4 +38,5 @@ public class GlobalThreadPoolManage {
public static void registerPoolParameter(String tpId, PoolParameter poolParameter) {
POOL_PARAMETER.put(tpId, poolParameter);
}
}

17
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/InstanceInfo.java
Unescape View File

@ -1,12 +1,25 @@
package com.github.dynamic.threadpool.starter.core;
import lombok.Getter;
import lombok.Setter;
/**
* Instance Info.
*
* @author chen.ma
* @date 2021/7/13 22:10
*/
public class InstanceInfo {
@Getter
@Setter
public class InstanceInfo implements InstanceConfig {
private static final String UNKNOWN = "unknown";
private String appName = UNKNOWN;
private String hostName;
private String instanceId;
private String appName;
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/Listener.java
Unescape View File

@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.core;
import java.util.concurrent.Executor;
/**
* 监听器
* Listener.
*
* @author chen.ma
* @date 2021/6/22 20:20
@ -23,4 +23,5 @@ public interface Listener {
* @param configInfo
*/
void receiveConfigInfo(String configInfo);
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolConfigService.java
Unescape View File

@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import java.util.Arrays;
/**
* 线程池配置服务
* ThreadPool Config Service.
*
* @author chen.ma
* @date 2021/6/21 21:50
@ -34,4 +34,5 @@ public class ThreadPoolConfigService implements ConfigService {
return "DOWN";
}
}
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolDynamicRefresh.java
Unescape View File

@ -12,7 +12,7 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
* 线程池动态刷新
* ThreadPool Dynamic Refresh.
*
* @author chen.ma
* @date 2021/6/20 15:51

7
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolOperation.java
Unescape View File

@ -1,6 +1,6 @@
package com.github.dynamic.threadpool.starter.core;
import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import com.github.dynamic.threadpool.starter.config.BootstrapProperties;
import java.util.concurrent.Executor;
@ -14,9 +14,9 @@ public class ThreadPoolOperation {
private final ConfigService configService;
private final DynamicThreadPoolProperties properties;
private final BootstrapProperties properties;
public ThreadPoolOperation(DynamicThreadPoolProperties properties, ConfigService configService) {
public ThreadPoolOperation(BootstrapProperties properties, ConfigService configService) {
this.properties = properties;
this.configService = configService;
}
@ -38,4 +38,5 @@ public class ThreadPoolOperation {
return configListener;
}
}

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/core/ThreadPoolSubscribeCallback.java
Unescape View File

@ -14,4 +14,5 @@ public interface ThreadPoolSubscribeCallback {
* @param config
*/
void callback(String config);
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/EnableDynamicThreadPool.java
Unescape View File

@ -13,7 +13,7 @@ import java.lang.annotation.*;
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(DynamicThreadPoolMarkerConfiguration.class)
@Import(MarkerConfiguration.class)
public @interface EnableDynamicThreadPool {
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/DynamicThreadPoolMarkerConfiguration.java → dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/enable/MarkerConfiguration.java
Unescape View File

@ -10,7 +10,7 @@ import org.springframework.context.annotation.Configuration;
* @date 2021/7/8 23:30
*/
@Configuration(proxyBeanMethods = false)
public class DynamicThreadPoolMarkerConfiguration {
public class MarkerConfiguration {
@Bean
public Marker dynamicThreadPoolMarkerBean() {
@ -20,4 +20,5 @@ public class DynamicThreadPoolMarkerConfiguration {
public class Marker {
}
}

8
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/ThreadPoolBannerHandler.java → dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/DynamicThreadPoolBannerHandler.java
Unescape View File

@ -1,6 +1,6 @@
package com.github.dynamic.threadpool.starter.handler;
import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import com.github.dynamic.threadpool.starter.config.BootstrapProperties;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@ -17,10 +17,10 @@ import org.springframework.boot.ansi.AnsiStyle;
*/
@Slf4j
@RequiredArgsConstructor
public class ThreadPoolBannerHandler implements InitializingBean {
public class DynamicThreadPoolBannerHandler implements InitializingBean {
@NonNull
private final DynamicThreadPoolProperties properties;
private final BootstrapProperties properties;
private final String DYNAMIC_THREAD_POOL = " :: Dynamic ThreadPool :: ";
@ -53,7 +53,7 @@ public class ThreadPoolBannerHandler implements InitializingBean {
}
public static String getVersion() {
final Package pkg = ThreadPoolBannerHandler.class.getPackage();
final Package pkg = DynamicThreadPoolBannerHandler.class.getPackage();
return pkg != null ? pkg.getImplementationVersion() : "";
}

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/handler/ThreadPoolRunStateHandler.java
Unescape View File

@ -87,4 +87,5 @@ public class ThreadPoolRunStateHandler {
private static String divide(int num1, int num2) {
return ((int) (Double.parseDouble(num1 + "") / Double.parseDouble(num2 + "") * 100)) + "%";
}
}

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/HttpAgent.java
Unescape View File

@ -75,4 +75,5 @@ public interface HttpAgent {
*/
Result httpDeleteByConfig(String path, Map<String, String> headers, Map<String, String> paramValues,
long readTimeoutMs);
}

6
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerHttpAgent.java
Unescape View File

@ -1,7 +1,7 @@
package com.github.dynamic.threadpool.starter.remote;
import com.github.dynamic.threadpool.common.web.base.Result;
import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import com.github.dynamic.threadpool.starter.config.BootstrapProperties;
import com.github.dynamic.threadpool.starter.toolkit.HttpClientUtil;
import java.util.Map;
@ -14,13 +14,13 @@ import java.util.Map;
*/
public class ServerHttpAgent implements HttpAgent {
private final DynamicThreadPoolProperties dynamicThreadPoolProperties;
private final BootstrapProperties dynamicThreadPoolProperties;
private final ServerListManager serverListManager;
private final HttpClientUtil httpClientUtil;
public ServerHttpAgent(DynamicThreadPoolProperties properties, HttpClientUtil httpClientUtil) {
public ServerHttpAgent(BootstrapProperties properties, HttpClientUtil httpClientUtil) {
this.dynamicThreadPoolProperties = properties;
this.httpClientUtil = httpClientUtil;
this.serverListManager = new ServerListManager(dynamicThreadPoolProperties);

7
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/remote/ServerListManager.java
Unescape View File

@ -1,6 +1,6 @@
package com.github.dynamic.threadpool.starter.remote;
import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import com.github.dynamic.threadpool.starter.config.BootstrapProperties;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.StringUtils;
@ -27,9 +27,9 @@ public class ServerListManager {
private Iterator<String> iterator;
private final DynamicThreadPoolProperties properties;
private final BootstrapProperties properties;
public ServerListManager(DynamicThreadPoolProperties dynamicThreadPoolProperties) {
public ServerListManager(BootstrapProperties dynamicThreadPoolProperties) {
this.properties = dynamicThreadPoolProperties;
serverAddrsStr = properties.getServerAddr();
@ -122,5 +122,4 @@ public class ServerListManager {
}
}
}

6
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomBlockingQueue.java
Unescape View File

@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.spi;
import java.util.concurrent.BlockingQueue;
/**
* 自定义阻塞队列
* Custom BlockingQueue.
*
* @author chen.ma
* @date 2021/7/11 00:51
@ -11,14 +11,14 @@ import java.util.concurrent.BlockingQueue;
public interface CustomBlockingQueue {
/**
* 获取类型
* Gets the custom blocking queue type.
*
* @return
*/
Integer getType();
/**
* 生成阻塞队列
* Get custom blocking queue.
*
* @return
*/

6
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/CustomRejectedExecutionHandler.java
Unescape View File

@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.spi;
import java.util.concurrent.RejectedExecutionHandler;
/**
* 自定义拒绝策略
* Custom RejectedExecution Handler.
*
* @author chen.ma
* @date 2021/7/10 23:51
@ -11,14 +11,14 @@ import java.util.concurrent.RejectedExecutionHandler;
public interface CustomRejectedExecutionHandler {
/**
* 获取类型
* Get custom reject policy type.
*
* @return
*/
Integer getType();
/**
* 生成拒绝策略
* Get custom reject policy.
*
* @return
*/

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/spi/DynamicTpServiceLoader.java
Unescape View File

@ -43,4 +43,5 @@ public class DynamicTpServiceLoader {
throw new ServiceLoaderInstantiationException(clazz, ex);
}
}
}

1
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/ArrayUtil.java
Unescape View File

@ -38,4 +38,5 @@ public class ArrayUtil {
}
return array.clone();
}
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/HttpClientUtil.java
Unescape View File

@ -11,7 +11,7 @@ import java.util.Map;
import java.util.concurrent.TimeUnit;
/**
* Http 客户端工具类
* HttpClient Util.
*
* @author chen.ma
* @date 2021/6/10 13:30

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java
Unescape View File

@ -9,7 +9,7 @@ import java.util.concurrent.*;
import java.util.concurrent.locks.AbstractQueuedSynchronizer;
/**
* 抽象线程池模版构建
* Abstract Build ThreadPool Template.
*
* @author chen.ma
* @date 2021/7/5 21:45
@ -157,4 +157,5 @@ public class AbstractBuildThreadPoolTemplate {
.build();
}
}
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/Builder.java
Unescape View File

@ -3,7 +3,7 @@ package com.github.dynamic.threadpool.starter.toolkit.thread;
import java.io.Serializable;
/**
* 建造者模式接口定义
* Builder pattern interface definition.
*
* @author chen.ma
* @date 2021/7/5 21:39

4
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/FastThreadPoolExecutor.java
Unescape View File

@ -9,9 +9,7 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
/**
* 快速执行任务线程池, 参考 Dubbo 线程模型 EagerThreadPoolExecutor
* <p>
* 配合 {@link TaskQueue}
* Fast ThreadPool Executor.
*
* @author chen.ma
* @date 2021/7/5 21:00

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/QueueTypeEnum.java
Unescape View File

@ -9,7 +9,7 @@ import java.util.Optional;
import java.util.concurrent.*;
/**
* 队列类型枚举
* Queue Type Enum.
*
* @author chen.ma
* @date 2021/6/25 12:30
@ -89,4 +89,5 @@ public enum QueueTypeEnum {
return blockingQueue;
}
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/RejectedPolicies.java
Unescape View File

@ -6,7 +6,7 @@ import java.util.concurrent.BlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
/**
* 线程池拒绝策略
* Rejected Policies.
*
* @author chen.ma
* @date 2021/7/5 21:23
@ -53,4 +53,5 @@ public class RejectedPolicies {
}
};
}
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/RejectedTypeEnum.java
Unescape View File

@ -11,7 +11,7 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.stream.Stream;
/**
* 拒绝策略类型枚举
* Reject policy type Enum.
*
* @author chen.ma
* @date 2021/7/10 23:16

5
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ResizableCapacityLinkedBlockIngQueue.java
Unescape View File

@ -6,7 +6,7 @@ import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.LinkedBlockingQueue;
/**
* 可调整大小的阻塞队列
* Resizable Capacity LinkedBlockIngQueue.
*
* @author chen.ma
* @date 2021/6/20 14:24
@ -24,9 +24,10 @@ public class ResizableCapacityLinkedBlockIngQueue<E> extends LinkedBlockingQueue
ReflectUtil.setFieldValue(this, "capacity", capacity);
} catch (Exception ex) {
// ignore
log.error("动态修改阻塞队列大小失败.", ex);
log.error("Dynamic modification of blocking queue size failed.", ex);
successFlag = false;
}
return successFlag;
}
}

6
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/TaskQueue.java
Unescape View File

@ -5,9 +5,7 @@ import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.TimeUnit;
/**
* 快速执行任务而阻塞队列, 参考 Dubbo 重写队列 TaskQueue
* <p>
* 配合 {@link FastThreadPoolExecutor} 使用
* Task Queue.
*
* @author chen.ma
* @date 2021/7/5 21:00
@ -45,7 +43,7 @@ public class TaskQueue<R extends Runnable> extends LinkedBlockingQueue<Runnable>
public boolean retryOffer(Runnable o, long timeout, TimeUnit unit) throws InterruptedException {
if (executor.isShutdown()) {
throw new RejectedExecutionException("执行器已关闭!");
throw new RejectedExecutionException("Actuator closed!");
}
return super.offer(o, timeout, unit);
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadFactoryBuilder.java
Unescape View File

@ -5,7 +5,7 @@ import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicLong;
/**
* ThreadFactory 创建器
* ThreadFactory Builder.
*
* @author chen.ma
* @date 2021/7/5 21:53
@ -152,4 +152,5 @@ public class ThreadFactoryBuilder implements Builder<ThreadFactory> {
return thread;
};
}
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java
Unescape View File

@ -7,7 +7,7 @@ import java.math.BigDecimal;
import java.util.concurrent.*;
/**
* 线程池构造器
* ThreadPool Builder.
*
* @author chen.ma
* @date 2021/6/28 17:29
@ -243,4 +243,5 @@ public class ThreadPoolBuilder implements Builder<ThreadPoolExecutor> {
return initParam;
}
}

3
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/toolkit/thread/ThreadPoolExecutorTemplate.java
Unescape View File

@ -5,7 +5,7 @@ import com.github.dynamic.threadpool.starter.toolkit.ArrayUtil;
import java.util.concurrent.*;
/**
* 线程池创建模版
* ThreadPool Executor Template.
*
* @author chen.ma
* @date 2021/7/5 21:59
@ -62,4 +62,5 @@ public class ThreadPoolExecutorTemplate extends ThreadPoolExecutor {
}
};
}
}

2
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/DynamicThreadPoolWrap.java
Unescape View File

@ -8,7 +8,7 @@ import java.util.concurrent.Future;
import java.util.concurrent.ThreadPoolExecutor;
/**
* 线程池包装
* Dynamic ThreadPool Wrap.
*
* @author chen.ma
* @date 2021/6/20 16:55

7
dynamic-threadpool-spring-boot-starter/src/main/java/com/github/dynamic/threadpool/starter/wrap/ManagerListenerWrap.java
Unescape View File

@ -5,7 +5,7 @@ import lombok.Getter;
import lombok.Setter;
/**
* 监听包装
* Manager Listener Wrap.
*
* @author chen.ma
* @date 2021/6/22 17:47
@ -14,12 +14,13 @@ import lombok.Setter;
@Setter
public class ManagerListenerWrap {
final Listener listener;
private String lastCallMd5;
String lastCallMd5;
final Listener listener;
public ManagerListenerWrap(String md5, Listener listener) {
this.lastCallMd5 = md5;
this.listener = listener;
}
}

Write Preview
Loading…
Cancel
Save