Code Review - Behavior of FixedRate and FixedDelay should be similar …

redisson · Jul 4, 2023 · 36f2038 · 36f2038
1 parent b573574
commit 36f2038
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/redisson/src/main/java/org/redisson/executor/TasksRunnerService.java b/redisson/src/main/java/org/redisson/executor/TasksRunnerService.java
@@ -124,6 +124,10 @@ public void setTerminationTopicName(String terminationTopicName) {
     public void scheduleAtFixedRate(ScheduledAtFixedRateParameters params) {
         long start = System.nanoTime();
         executeRunnable(params, false);
+        if (!redisson.getMap(tasksName, StringCodec.INSTANCE).containsKey(params.getRequestId())) {
+            return;
+        }
+
         long spent = params.getSpentTime()
                                 + TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start);