dromara/dynamic-tp
dromara/dynamic-tp
1
0
Fork 0
mirror of https://github.com/dromara/dynamic-tp.git synced 2024-10-23 08:34:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #493] remove AwareManager.execute for schedule executor

Browse Source
This commit is contained in:
yanhom 2024-10-22 23:17:37 +08:00
parent bfea3b2621
commit 0c3ed380d3
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
core/src/main/java/org/dromara/dynamictp/core/support/ScheduledThreadPoolExecutorProxy.java
View File

@ -58,34 +58,29 @@ public class ScheduledThreadPoolExecutorProxy extends ScheduledThreadPoolExecuto
@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);
}