Skip to content

Commit c0c46f5

Browse files
committed
avoid race condition if fast tests
1 parent 89b2f30 commit c0c46f5

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

core/src/main/java/org/sterl/spring/persistent_tasks/scheduler/component/TaskExecutorComponent.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,11 +74,14 @@ public Future<TriggerKey> submit(@Nullable TriggerEntity trigger) {
7474
throw new IllegalStateException("Executor of " + schedulerName + " is already stopped");
7575
}
7676

77+
7778
try {
79+
Future<TriggerKey> result;
7880
synchronized (runningTasks) {
79-
runningTasks.put(trigger, executor.submit(() -> runTrigger(trigger)));
81+
result = executor.submit(() -> runTrigger(trigger));
82+
runningTasks.put(trigger, result);
8083
}
81-
return runningTasks.get(trigger);
84+
return result;
8285
} catch (Exception e) {
8386
runningTasks.remove(trigger);
8487
throw new RuntimeException("Failed to run " + trigger.getKey(), e);

0 commit comments

Comments
 (0)