From bf68d514235a67fa6221f65f9f626c65c1d1188c Mon Sep 17 00:00:00 2001 From: yanhom Date: Sun, 17 Nov 2024 23:26:25 +0800 Subject: [PATCH] optimize --- .../dromara/dynamictp/adapter/common/AbstractDtpAdapter.java | 2 +- .../src/main/java/org/dromara/dynamictp/core/DtpRegistry.java | 2 +- .../org/dromara/dynamictp/core/aware/TaskRejectAware.java | 2 +- .../dromara/dynamictp/core/converter/ExecutorConverter.java | 2 +- .../java/org/dromara/dynamictp/core/executor/DtpExecutor.java | 2 +- .../core/notifier/capture/CapturedBlockingQueue.java | 2 +- .../dynamictp/core/notifier/capture/CapturedExecutor.java | 2 +- .../dromara/dynamictp/core/refresher/AbstractRefresher.java | 1 - .../org/dromara/dynamictp/core/support/ExecutorWrapper.java | 2 ++ .../dynamictp/core/support/{ => adapter}/ExecutorAdapter.java | 2 +- .../core/support/{ => adapter}/ThreadPoolExecutorAdapter.java | 2 +- .../dromara/dynamictp/core/timer/QueueTimeoutTimerTask.java | 2 +- .../org/dromara/dynamictp/core/timer/RunTimeoutTimerTask.java | 2 +- .../starter/adapter/webserver/jetty/JettyDtpAdapter.java | 2 +- .../starter/adapter/webserver/tomcat/TomcatDtpAdapter.java | 2 +- .../taskpool/EnhancedQueueExecutorTaskPoolAdapter.java | 2 +- .../undertow/taskpool/ExecutorServiceTaskPoolAdapter.java | 4 ++-- .../webserver/undertow/taskpool/ExternalTaskPoolAdapter.java | 2 +- .../adapter/webserver/undertow/taskpool/TaskPoolAdapter.java | 2 +- .../undertow/taskpool/ThreadPoolExecutorTaskPoolAdapter.java | 4 ++-- .../test/core/notify/capture/CapturedExecutorTest.java | 4 ++-- 21 files changed, 24 insertions(+), 23 deletions(-) rename core/src/main/java/org/dromara/dynamictp/core/support/{ => adapter}/ExecutorAdapter.java (99%) rename core/src/main/java/org/dromara/dynamictp/core/support/{ => adapter}/ThreadPoolExecutorAdapter.java (98%) diff --git a/adapter/adapter-common/src/main/java/org/dromara/dynamictp/adapter/common/AbstractDtpAdapter.java b/adapter/adapter-common/src/main/java/org/dromara/dynamictp/adapter/common/AbstractDtpAdapter.java index 604d0676b..53b68371d 100644 --- a/adapter/adapter-common/src/main/java/org/dromara/dynamictp/adapter/common/AbstractDtpAdapter.java +++ b/adapter/adapter-common/src/main/java/org/dromara/dynamictp/adapter/common/AbstractDtpAdapter.java @@ -41,7 +41,7 @@ import org.dromara.dynamictp.core.aware.AwareManager; import org.dromara.dynamictp.core.converter.ExecutorConverter; import org.dromara.dynamictp.core.notifier.manager.NoticeManager; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ExecutorWrapper; import org.dromara.dynamictp.core.support.proxy.ThreadPoolExecutorProxy; import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper; diff --git a/core/src/main/java/org/dromara/dynamictp/core/DtpRegistry.java b/core/src/main/java/org/dromara/dynamictp/core/DtpRegistry.java index f711951c3..ac1518bdf 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/DtpRegistry.java +++ b/core/src/main/java/org/dromara/dynamictp/core/DtpRegistry.java @@ -42,7 +42,7 @@ import org.dromara.dynamictp.core.notifier.manager.NoticeManager; import org.dromara.dynamictp.core.notifier.manager.NotifyHelper; import org.dromara.dynamictp.core.reject.RejectHandlerGetter; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ExecutorWrapper; import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper; import org.dromara.dynamictp.core.support.task.wrapper.TaskWrappers; diff --git a/core/src/main/java/org/dromara/dynamictp/core/aware/TaskRejectAware.java b/core/src/main/java/org/dromara/dynamictp/core/aware/TaskRejectAware.java index d7c18b12d..ffb0af7b0 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/aware/TaskRejectAware.java +++ b/core/src/main/java/org/dromara/dynamictp/core/aware/TaskRejectAware.java @@ -20,7 +20,7 @@ import cn.hutool.core.text.CharSequenceUtil; import lombok.extern.slf4j.Slf4j; import org.dromara.dynamictp.core.notifier.manager.AlarmManager; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ThreadPoolStatProvider; import org.slf4j.MDC; diff --git a/core/src/main/java/org/dromara/dynamictp/core/converter/ExecutorConverter.java b/core/src/main/java/org/dromara/dynamictp/core/converter/ExecutorConverter.java index 48d333321..3688755f1 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/converter/ExecutorConverter.java +++ b/core/src/main/java/org/dromara/dynamictp/core/converter/ExecutorConverter.java @@ -22,7 +22,7 @@ import org.dromara.dynamictp.common.entity.TpMainFields; import org.dromara.dynamictp.core.executor.DtpExecutor; import org.dromara.dynamictp.core.monitor.PerformanceProvider; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ExecutorWrapper; import org.dromara.dynamictp.core.support.ThreadPoolStatProvider; diff --git a/core/src/main/java/org/dromara/dynamictp/core/executor/DtpExecutor.java b/core/src/main/java/org/dromara/dynamictp/core/executor/DtpExecutor.java index 8981e0b60..25be905fa 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/executor/DtpExecutor.java +++ b/core/src/main/java/org/dromara/dynamictp/core/executor/DtpExecutor.java @@ -28,7 +28,7 @@ import org.dromara.dynamictp.core.aware.TaskEnhanceAware; import org.dromara.dynamictp.core.notifier.manager.NotifyHelper; import org.dromara.dynamictp.core.reject.RejectHandlerGetter; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper; import java.util.List; diff --git a/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedBlockingQueue.java b/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedBlockingQueue.java index 96fbb068b..dbfc71fe7 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedBlockingQueue.java +++ b/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedBlockingQueue.java @@ -17,7 +17,7 @@ package org.dromara.dynamictp.core.notifier.capture; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import java.util.AbstractQueue; import java.util.Collection; diff --git a/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedExecutor.java b/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedExecutor.java index d03b5d860..13a59e1aa 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedExecutor.java +++ b/core/src/main/java/org/dromara/dynamictp/core/notifier/capture/CapturedExecutor.java @@ -23,7 +23,7 @@ import org.dromara.dynamictp.core.notifier.AbstractDtpNotifier; import org.dromara.dynamictp.core.notifier.context.BaseNotifyCtx; import org.dromara.dynamictp.core.notifier.manager.AlarmManager; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import java.util.concurrent.BlockingQueue; import java.util.concurrent.RejectedExecutionHandler; diff --git a/core/src/main/java/org/dromara/dynamictp/core/refresher/AbstractRefresher.java b/core/src/main/java/org/dromara/dynamictp/core/refresher/AbstractRefresher.java index 8e064ba2e..7896109c9 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/refresher/AbstractRefresher.java +++ b/core/src/main/java/org/dromara/dynamictp/core/refresher/AbstractRefresher.java @@ -29,7 +29,6 @@ import org.dromara.dynamictp.core.handler.ConfigHandler; import org.dromara.dynamictp.core.support.binder.BinderHelper; - import java.io.IOException; import java.util.Map; import java.util.Objects; diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java b/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java index dc4a71310..7101a44ed 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java +++ b/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorWrapper.java @@ -28,6 +28,8 @@ import org.dromara.dynamictp.core.notifier.capture.CapturedExecutor; import org.dromara.dynamictp.core.notifier.manager.AlarmManager; import org.dromara.dynamictp.core.reject.RejectHandlerGetter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ThreadPoolExecutorAdapter; import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper; import java.util.HashSet; diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorAdapter.java b/core/src/main/java/org/dromara/dynamictp/core/support/adapter/ExecutorAdapter.java similarity index 99% rename from core/src/main/java/org/dromara/dynamictp/core/support/ExecutorAdapter.java rename to core/src/main/java/org/dromara/dynamictp/core/support/adapter/ExecutorAdapter.java index abd12ff56..cca52fc26 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/support/ExecutorAdapter.java +++ b/core/src/main/java/org/dromara/dynamictp/core/support/adapter/ExecutorAdapter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.dromara.dynamictp.core.support; +package org.dromara.dynamictp.core.support.adapter; import java.util.AbstractQueue; import java.util.Collection; diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolExecutorAdapter.java b/core/src/main/java/org/dromara/dynamictp/core/support/adapter/ThreadPoolExecutorAdapter.java similarity index 98% rename from core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolExecutorAdapter.java rename to core/src/main/java/org/dromara/dynamictp/core/support/adapter/ThreadPoolExecutorAdapter.java index ec540d700..de6f1e0f2 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/support/ThreadPoolExecutorAdapter.java +++ b/core/src/main/java/org/dromara/dynamictp/core/support/adapter/ThreadPoolExecutorAdapter.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.dromara.dynamictp.core.support; +package org.dromara.dynamictp.core.support.adapter; import org.dromara.dynamictp.core.aware.RejectHandlerAware; diff --git a/core/src/main/java/org/dromara/dynamictp/core/timer/QueueTimeoutTimerTask.java b/core/src/main/java/org/dromara/dynamictp/core/timer/QueueTimeoutTimerTask.java index 2a20626c6..2bbb82a3c 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/timer/QueueTimeoutTimerTask.java +++ b/core/src/main/java/org/dromara/dynamictp/core/timer/QueueTimeoutTimerTask.java @@ -21,7 +21,7 @@ import lombok.extern.slf4j.Slf4j; import lombok.val; import org.dromara.dynamictp.core.notifier.manager.AlarmManager; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ExecutorWrapper; import static org.dromara.dynamictp.common.em.NotifyItemEnum.QUEUE_TIMEOUT; diff --git a/core/src/main/java/org/dromara/dynamictp/core/timer/RunTimeoutTimerTask.java b/core/src/main/java/org/dromara/dynamictp/core/timer/RunTimeoutTimerTask.java index 70d759bce..3bf958a38 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/timer/RunTimeoutTimerTask.java +++ b/core/src/main/java/org/dromara/dynamictp/core/timer/RunTimeoutTimerTask.java @@ -21,7 +21,7 @@ import lombok.extern.slf4j.Slf4j; import lombok.val; import org.dromara.dynamictp.core.notifier.manager.AlarmManager; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ExecutorWrapper; import static org.dromara.dynamictp.common.em.NotifyItemEnum.RUN_TIMEOUT; diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/jetty/JettyDtpAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/jetty/JettyDtpAdapter.java index e8cef06e0..6957f947d 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/jetty/JettyDtpAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/jetty/JettyDtpAdapter.java @@ -20,7 +20,7 @@ import lombok.extern.slf4j.Slf4j; import org.dromara.dynamictp.common.properties.DtpProperties; import org.dromara.dynamictp.common.util.ReflectionUtil; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ExecutorWrapper; import org.dromara.dynamictp.starter.adapter.webserver.AbstractWebServerDtpAdapter; import org.eclipse.jetty.io.ManagedSelector; diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/tomcat/TomcatDtpAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/tomcat/TomcatDtpAdapter.java index 7c56e3840..49ba8e7cd 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/tomcat/TomcatDtpAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/tomcat/TomcatDtpAdapter.java @@ -23,7 +23,7 @@ import org.apache.tomcat.util.threads.ThreadPoolExecutor; import org.dromara.dynamictp.common.properties.DtpProperties; import org.dromara.dynamictp.core.aware.RejectHandlerAware; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.starter.adapter.webserver.AbstractWebServerDtpAdapter; import org.springframework.boot.web.embedded.tomcat.TomcatWebServer; import org.springframework.boot.web.server.WebServer; diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/EnhancedQueueExecutorTaskPoolAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/EnhancedQueueExecutorTaskPoolAdapter.java index 315fe86f7..33b0ce646 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/EnhancedQueueExecutorTaskPoolAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/EnhancedQueueExecutorTaskPoolAdapter.java @@ -17,7 +17,7 @@ package org.dromara.dynamictp.starter.adapter.webserver.undertow.taskpool; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.starter.adapter.webserver.undertow.UndertowTaskPoolEnum; import org.jboss.threads.EnhancedQueueExecutor; diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExecutorServiceTaskPoolAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExecutorServiceTaskPoolAdapter.java index fe0071440..2bcedbc9e 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExecutorServiceTaskPoolAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExecutorServiceTaskPoolAdapter.java @@ -18,8 +18,8 @@ package org.dromara.dynamictp.starter.adapter.webserver.undertow.taskpool; import org.dromara.dynamictp.starter.adapter.webserver.undertow.UndertowTaskPoolEnum; -import org.dromara.dynamictp.core.support.ExecutorAdapter; -import org.dromara.dynamictp.core.support.ThreadPoolExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ThreadPoolExecutorAdapter; import java.util.concurrent.ThreadPoolExecutor; diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExternalTaskPoolAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExternalTaskPoolAdapter.java index 813ccdcd3..ff7ceb949 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExternalTaskPoolAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ExternalTaskPoolAdapter.java @@ -20,7 +20,7 @@ import org.dromara.dynamictp.starter.adapter.webserver.undertow.TaskPoolHandlerFactory; import org.dromara.dynamictp.starter.adapter.webserver.undertow.UndertowTaskPoolEnum; import org.dromara.dynamictp.common.util.ReflectionUtil; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import lombok.val; /** diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/TaskPoolAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/TaskPoolAdapter.java index f2d4a8f7f..0daa05ad7 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/TaskPoolAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/TaskPoolAdapter.java @@ -18,7 +18,7 @@ package org.dromara.dynamictp.starter.adapter.webserver.undertow.taskpool; import org.dromara.dynamictp.starter.adapter.webserver.undertow.UndertowTaskPoolEnum; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import java.util.concurrent.Executor; diff --git a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ThreadPoolExecutorTaskPoolAdapter.java b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ThreadPoolExecutorTaskPoolAdapter.java index b3bc10f57..6d28dde27 100644 --- a/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ThreadPoolExecutorTaskPoolAdapter.java +++ b/starter/starter-adapter/starter-adapter-webserver/src/main/java/org/dromara/dynamictp/starter/adapter/webserver/undertow/taskpool/ThreadPoolExecutorTaskPoolAdapter.java @@ -18,8 +18,8 @@ package org.dromara.dynamictp.starter.adapter.webserver.undertow.taskpool; import org.dromara.dynamictp.starter.adapter.webserver.undertow.UndertowTaskPoolEnum; -import org.dromara.dynamictp.core.support.ExecutorAdapter; -import org.dromara.dynamictp.core.support.ThreadPoolExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ThreadPoolExecutorAdapter; import java.util.concurrent.ThreadPoolExecutor; diff --git a/test/test-core/src/test/java/org/dromara/dynamictp/test/core/notify/capture/CapturedExecutorTest.java b/test/test-core/src/test/java/org/dromara/dynamictp/test/core/notify/capture/CapturedExecutorTest.java index 01adf134e..98606227c 100644 --- a/test/test-core/src/test/java/org/dromara/dynamictp/test/core/notify/capture/CapturedExecutorTest.java +++ b/test/test-core/src/test/java/org/dromara/dynamictp/test/core/notify/capture/CapturedExecutorTest.java @@ -18,10 +18,10 @@ package org.dromara.dynamictp.test.core.notify.capture; import org.dromara.dynamictp.core.notifier.capture.CapturedExecutor; -import org.dromara.dynamictp.core.support.ExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter; import org.dromara.dynamictp.core.support.ThreadPoolBuilder; import org.dromara.dynamictp.core.support.ThreadPoolCreator; -import org.dromara.dynamictp.core.support.ThreadPoolExecutorAdapter; +import org.dromara.dynamictp.core.support.adapter.ThreadPoolExecutorAdapter; import org.dromara.dynamictp.core.executor.DtpExecutor; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.BeforeAll;