diff --git a/test/test-core/src/test/java/org/dromara/dynamictp/test/core/thread/ScheduledDtpExecutorTest.java b/test/test-core/src/test/java/org/dromara/dynamictp/test/core/thread/ScheduledDtpExecutorTest.java index f3a7f4776..fd9d2f946 100644 --- a/test/test-core/src/test/java/org/dromara/dynamictp/test/core/thread/ScheduledDtpExecutorTest.java +++ b/test/test-core/src/test/java/org/dromara/dynamictp/test/core/thread/ScheduledDtpExecutorTest.java @@ -42,15 +42,14 @@ class ScheduledDtpExecutorTest { @Test - void schedule() throws InterruptedException { + void schedule() { ScheduledDtpExecutor dtpExecutor12 = (ScheduledDtpExecutor) DtpRegistry.getExecutor("dtpExecutor12"); System.out.println(dtpExecutor12.getClass()); dtpExecutor12.scheduleAtFixedRate(() -> { System.out.println(Thread.currentThread().getName() + "进来了," + "当前时间是 " + LocalDateTime.now()); }, 10, 5, TimeUnit.SECONDS); -// dtpExecutor12.shutdownNow(); - TimeUnit.SECONDS.sleep(10000); + dtpExecutor12.shutdownNow(); } @Test diff --git a/test/test-core/src/test/resources/dynamic-tp-nacos-demo-dtp-dev.yml b/test/test-core/src/test/resources/dynamic-tp-nacos-demo-dtp-dev.yml index a3ca6b8cd..0b47afd99 100644 --- a/test/test-core/src/test/resources/dynamic-tp-nacos-demo-dtp-dev.yml +++ b/test/test-core/src/test/resources/dynamic-tp-nacos-demo-dtp-dev.yml @@ -123,7 +123,7 @@ dynamictp: preStartAllCoreThreads: false # 是否预热所有核心线程,默认false runTimeout: 200 # 任务执行超时阈值,目前只做告警用,单位(ms) queueTimeout: 100 # 任务在队列等待超时阈值,目前只做告警用,单位(ms) - taskWrapperNames: ["ttl", "mdc"] # 任务包装器名称,集成TaskWrapper接口 + taskWrapperNames: ["ttl"] # 任务包装器名称,集成TaskWrapper接口 notifyItems: # 报警项,不配置自动会按默认值配置(变更通知、容量报警、活性报警、拒绝报警、任务超时报警) - type: capacity # 报警项类型,查看源码 NotifyTypeEnum枚举类 enabled: true