Skip to content

Commit

Permalink
Merge pull request #494 from dromara/fix-493
Browse files Browse the repository at this point in the history
[ISSUE #493] remove AwareManager.execute for schedule executor
  • Loading branch information
yanhom1314 authored Oct 22, 2024
2 parents bfea3b2 + 0c3ed38 commit 961ba60
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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 <V> ScheduledFuture<V> 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);
}

Expand Down

0 comments on commit 961ba60

Please sign in to comment.