Skip to content

Commit f6003d1

Browse files
committed
feat: add unregister executor method
1 parent f055c01 commit f6003d1

File tree

1 file changed

+13
-1
lines changed

1 file changed

+13
-1
lines changed

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

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,8 @@
4242
import org.dromara.dynamictp.core.notifier.manager.NoticeManager;
4343
import org.dromara.dynamictp.core.notifier.manager.NotifyHelper;
4444
import org.dromara.dynamictp.core.reject.RejectHandlerGetter;
45-
import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter;
4645
import org.dromara.dynamictp.core.support.ExecutorWrapper;
46+
import org.dromara.dynamictp.core.support.adapter.ExecutorAdapter;
4747
import org.dromara.dynamictp.core.support.task.wrapper.TaskWrapper;
4848
import org.dromara.dynamictp.core.support.task.wrapper.TaskWrappers;
4949

@@ -117,6 +117,18 @@ public static void registerExecutor(ExecutorWrapper wrapper, String source) {
117117
EXECUTOR_REGISTRY.putIfAbsent(wrapper.getThreadPoolName(), wrapper);
118118
}
119119

120+
/**
121+
* Unregister a executor.
122+
*
123+
* @param name thread pool name
124+
* @return the managed DtpExecutor instance
125+
*/
126+
public static ExecutorWrapper unregisterExecutor(String name) {
127+
ExecutorWrapper executorWrapper = getExecutorWrapper(name);
128+
log.info("DynamicTp unregister executor: {}", executorWrapper);
129+
return EXECUTOR_REGISTRY.remove(name);
130+
}
131+
120132
/**
121133
* Get DtpExecutor by thread pool name.
122134
*

0 commit comments

Comments
 (0)