|
|
@ -176,7 +176,6 @@ public final class DynamicThreadPoolPostProcessor implements BeanPostProcessor {
|
|
|
|
// DynamicThreadPool configuration undefined in server
|
|
|
|
// DynamicThreadPool configuration undefined in server
|
|
|
|
DynamicThreadPoolRegisterParameter parameterInfo = DynamicThreadPoolRegisterParameter.builder()
|
|
|
|
DynamicThreadPoolRegisterParameter parameterInfo = DynamicThreadPoolRegisterParameter.builder()
|
|
|
|
.threadPoolId(threadPoolId)
|
|
|
|
.threadPoolId(threadPoolId)
|
|
|
|
.threadNamePrefix(threadPoolId)
|
|
|
|
|
|
|
|
.corePoolSize(executor.getCorePoolSize())
|
|
|
|
.corePoolSize(executor.getCorePoolSize())
|
|
|
|
.maximumPoolSize(executor.getMaximumPoolSize())
|
|
|
|
.maximumPoolSize(executor.getMaximumPoolSize())
|
|
|
|
.blockingQueueType(BlockingQueueTypeEnum.getBlockingQueueTypeEnumByName(executor.getQueue().getClass().getSimpleName()))
|
|
|
|
.blockingQueueType(BlockingQueueTypeEnum.getBlockingQueueTypeEnumByName(executor.getQueue().getClass().getSimpleName()))
|
|
|
@ -184,6 +183,8 @@ public final class DynamicThreadPoolPostProcessor implements BeanPostProcessor {
|
|
|
|
.allowCoreThreadTimeOut(executor.allowsCoreThreadTimeOut())
|
|
|
|
.allowCoreThreadTimeOut(executor.allowsCoreThreadTimeOut())
|
|
|
|
.keepAliveTime(executor.getKeepAliveTime(TimeUnit.MILLISECONDS))
|
|
|
|
.keepAliveTime(executor.getKeepAliveTime(TimeUnit.MILLISECONDS))
|
|
|
|
.isAlarm(false)
|
|
|
|
.isAlarm(false)
|
|
|
|
|
|
|
|
.activeAlarm(80)
|
|
|
|
|
|
|
|
.capacityAlarm(80)
|
|
|
|
.rejectedPolicyType(RejectedPolicyTypeEnum.getRejectedPolicyTypeEnumByName(((DynamicThreadPoolExecutor) executor).getRedundancyHandler().getClass().getSimpleName()))
|
|
|
|
.rejectedPolicyType(RejectedPolicyTypeEnum.getRejectedPolicyTypeEnumByName(((DynamicThreadPoolExecutor) executor).getRedundancyHandler().getClass().getSimpleName()))
|
|
|
|
.build();
|
|
|
|
.build();
|
|
|
|
DynamicThreadPoolRegisterWrapper registerWrapper = DynamicThreadPoolRegisterWrapper.builder()
|
|
|
|
DynamicThreadPoolRegisterWrapper registerWrapper = DynamicThreadPoolRegisterWrapper.builder()
|
|
|
|