diff --git a/core/src/main/java/org/dromara/dynamictp/core/executor/ScheduledDtpExecutor.java b/core/src/main/java/org/dromara/dynamictp/core/executor/ScheduledDtpExecutor.java index 2c82f4c89b0736a66d9831b9acb99dad41a98c37..ef4bbf766f8948198237f927517347b3b7ff0ad3 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/executor/ScheduledDtpExecutor.java +++ b/core/src/main/java/org/dromara/dynamictp/core/executor/ScheduledDtpExecutor.java @@ -174,7 +174,7 @@ public class ScheduledDtpExecutor extends DtpExecutor implements ScheduledExecut @Override public void setMaximumPoolSize(int maximumPoolSize) { - delegate.setMaximumPoolSize(maximumPoolSize); + // cancel the assignment to maximumPoolSize } @Override @@ -190,7 +190,7 @@ public class ScheduledDtpExecutor extends DtpExecutor implements ScheduledExecut @Override public void setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut) { - delegate.allowCoreThreadTimeOut(allowCoreThreadTimeOut); + // cancel the assignment to allowCoreThreadTimeOut } @Override @@ -210,7 +210,7 @@ public class ScheduledDtpExecutor extends DtpExecutor implements ScheduledExecut @Override public void setKeepAliveTime(long time, TimeUnit unit) { - delegate.setKeepAliveTime(time, unit); + // cancel the assignment to keepAliveTime } @Override @@ -235,7 +235,7 @@ public class ScheduledDtpExecutor extends DtpExecutor implements ScheduledExecut @Override public void allowCoreThreadTimeOut(boolean value) { - delegate.allowCoreThreadTimeOut(value); + // cancel the assignment to allowCoreThreadTimeOut } @Override diff --git a/example/example-adapter/example-adapter-webserver/src/main/resources/application.yml b/example/example-adapter/example-adapter-webserver/src/main/resources/application.yml index cafa330db461805a2aeeb393a235b0016c74a883..81e4add442ac204895cb4b7cb1d9a35f744b490c 100644 --- a/example/example-adapter/example-adapter-webserver/src/main/resources/application.yml +++ b/example/example-adapter/example-adapter-webserver/src/main/resources/application.yml @@ -28,14 +28,14 @@ spring: executors: # 动态线程池配置,都有默认值,采用默认值的可以不配置该项,减少配置量 - threadPoolName: testExecutor threadPoolAliasName: 测试线程池 # 线程池别名 - executorType: common # 线程池类型common、eager:适用于io密集型 + executorType: scheduled # 线程池类型common、eager:适用于io密集型 corePoolSize: 6 maximumPoolSize: 8 queueCapacity: 100 queueType: LinkedBlockingQueue # 任务队列,查看源码QueueTypeEnum枚举类 rejectedHandlerType: CallerRunsPolicy # 拒绝策略,查看RejectedTypeEnum枚举类 keepAliveTime: 50 - allowCoreThreadTimeOut: false # 是否允许核心线程池超时 + allowCoreThreadTimeOut: true # 是否允许核心线程池超时 threadNamePrefix: test # 线程名前缀 waitForTasksToCompleteOnShutdown: false # 参考spring线程池设计,优雅关闭线程池 awaitTerminationSeconds: 5 # 单位(s)