diff --git a/core/src/main/java/org/dromara/dynamictp/core/support/ScheduledThreadPoolExecutorProxy.java b/core/src/main/java/org/dromara/dynamictp/core/support/ScheduledThreadPoolExecutorProxy.java index 4228a7d11..73d598030 100644 --- a/core/src/main/java/org/dromara/dynamictp/core/support/ScheduledThreadPoolExecutorProxy.java +++ b/core/src/main/java/org/dromara/dynamictp/core/support/ScheduledThreadPoolExecutorProxy.java @@ -58,34 +58,29 @@ public ScheduledThreadPoolExecutorProxy(ScheduledThreadPoolExecutor executor) { @Override public void execute(Runnable command) { command = getEnhancedTask(command); - AwareManager.execute(this, command); super.execute(command); } @Override public ScheduledFuture schedule(Runnable command, long delay, TimeUnit unit) { command = getEnhancedTask(command); - AwareManager.execute(this, command); return super.schedule(command, delay, unit); } public ScheduledFuture schedule(Runnable command, V result, long delay, TimeUnit unit) { command = getEnhancedTask(command); - AwareManager.execute(this, command); return super.schedule(Executors.callable(command, result), delay, unit); } @Override public ScheduledFuture scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) { command = getEnhancedTask(command); - AwareManager.execute(this, command); return super.scheduleAtFixedRate(command, initialDelay, period, unit); } @Override public ScheduledFuture scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) { command = getEnhancedTask(command); - AwareManager.execute(this, command); return super.scheduleWithFixedDelay(command, initialDelay, delay, unit); }