Polishing

See gh-30762
spring-projects · Jun 30, 2023 · 3c05679 · 3c05679
1 parent d8729a7
commit 3c05679
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/...text/src/main/java/org/springframework/scheduling/concurrent/ConcurrentTaskScheduler.java b/...text/src/main/java/org/springframework/scheduling/concurrent/ConcurrentTaskScheduler.java
@@ -212,10 +212,9 @@ public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {
 
 	@Override
 	public ScheduledFuture<?> schedule(Runnable task, Instant startTime) {
-		Duration initialDelay = Duration.between(this.clock.instant(), startTime);
+		Duration delay = Duration.between(this.clock.instant(), startTime);
 		try {
-			return this.scheduledExecutor.schedule(decorateTask(task, false),
-					NANO.convert(initialDelay), NANO);
+			return this.scheduledExecutor.schedule(decorateTask(task, false), NANO.convert(delay), NANO);
 		}
 		catch (RejectedExecutionException ex) {
 			throw new TaskRejectedException("Executor [" + this.scheduledExecutor + "] did not accept task: " + task, ex);

diff --git a/...text/src/main/java/org/springframework/scheduling/concurrent/ThreadPoolTaskScheduler.java b/...text/src/main/java/org/springframework/scheduling/concurrent/ThreadPoolTaskScheduler.java
@@ -383,10 +383,9 @@ public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {
 	@Override
 	public ScheduledFuture<?> schedule(Runnable task, Instant startTime) {
 		ScheduledExecutorService executor = getScheduledExecutor();
-		Duration initialDelay = Duration.between(this.clock.instant(), startTime);
+		Duration delay = Duration.between(this.clock.instant(), startTime);
 		try {
-			return executor.schedule(errorHandlingTask(task, false),
-					NANO.convert(initialDelay), NANO);
+			return executor.schedule(errorHandlingTask(task, false), NANO.convert(delay), NANO);
 		}
 		catch (RejectedExecutionException ex) {
 			throw new TaskRejectedException("Executor [" + executor + "] did not accept task: " + task, ex);