Merge pull request #522 from kvchoi/fix-bugs-20250205

Fix bugs 20250205

Author: yanhom1314

core/src/main/java/org/dromara/dynamictp/core/DtpRegistry.java

@@ -42,8 +42,8 @@
 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.adapter.ExecutorAdapter;
 import org.dromara.dynamictp.core.support.ExecutorWrapper;
+import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter;
 import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper;
 import org.dromara.dynamictp.core.support.task.wrapper.TaskWrappers;
 
@@ -117,6 +117,18 @@ public static void registerExecutor(ExecutorWrapper wrapper, String source) {
         EXECUTOR_REGISTRY.putIfAbsent(wrapper.getThreadPoolName(), wrapper);
     }
 
+    /**
+     * Unregister a executor.
+     *
+     * @param name thread pool name
+     * @return the managed DtpExecutor instance
+     */
+    public static ExecutorWrapper unregisterExecutor(String name) {
+        ExecutorWrapper executorWrapper = getExecutorWrapper(name);
+        log.info("DynamicTp unregister executor: {}", executorWrapper);
+        return EXECUTOR_REGISTRY.remove(name);
+    }
+
     /**
      * Get DtpExecutor by thread pool name.
      *

core/src/main/java/org/dromara/dynamictp/core/support/proxy/ScheduledThreadPoolExecutorProxy.java

@@ -52,7 +52,7 @@ public class ScheduledThreadPoolExecutorProxy extends ScheduledThreadPoolExecuto
     public ScheduledThreadPoolExecutorProxy(ScheduledThreadPoolExecutor executor) {
         super(executor.getCorePoolSize(), executor.getThreadFactory());
         this.rejectHandlerType = executor.getRejectedExecutionHandler().getClass().getSimpleName();
-        setRejectedExecutionHandler(RejectHandlerGetter.getProxy(getRejectedExecutionHandler()));
+        setRejectedExecutionHandler(RejectHandlerGetter.getProxy(executor.getRejectedExecutionHandler()));
     }
 
     @Override