org.springframework.scheduling.concurrent

Class ReschedulingRunnable

java.lang.Object

org.springframework.scheduling.support.DelegatingErrorHandlingRunnable

org.springframework.scheduling.concurrent.ReschedulingRunnable

All Implemented Interfaces:

java.lang.Comparable<java.util.concurrent.Delayed>, java.lang.Runnable, java.util.concurrent.Delayed, java.util.concurrent.Future<java.lang.Object>, java.util.concurrent.ScheduledFuture<java.lang.Object>

class ReschedulingRunnable
extends DelegatingErrorHandlingRunnable
implements java.util.concurrent.ScheduledFuture<java.lang.Object>

Internal adapter that reschedules an underlying Runnable according to the next execution time suggested by a given Trigger.

Necessary because a native ScheduledExecutorService supports delay-driven execution only. The flexibility of the Trigger interface will be translated onto a delay for the next execution time (repeatedly).

Since:

3.0

Author:

Juergen Hoeller, Mark Fisher

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.ScheduledFuture<?>	currentFuture
private java.util.concurrent.ScheduledExecutorService	executor
private java.util.Date	scheduledExecutionTime
private Trigger	trigger
private SimpleTriggerContext	triggerContext
private java.lang.Object	triggerContextMonitor

Constructor Summary

Constructors

Constructor and Description
ReschedulingRunnable(java.lang.Runnable delegate, Trigger trigger, java.util.concurrent.ScheduledExecutorService executor, ErrorHandler errorHandler)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
int	compareTo(java.util.concurrent.Delayed other)
java.lang.Object	get()
java.lang.Object	get(long timeout, java.util.concurrent.TimeUnit unit)
long	getDelay(java.util.concurrent.TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
void	run()
java.util.concurrent.ScheduledFuture<?>	schedule()

Methods inherited from class org.springframework.scheduling.support.DelegatingErrorHandlingRunnable

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

trigger

private final Trigger trigger

triggerContext

private final SimpleTriggerContext triggerContext

executor

private final java.util.concurrent.ScheduledExecutorService executor

currentFuture

private java.util.concurrent.ScheduledFuture<?> currentFuture

scheduledExecutionTime

private java.util.Date scheduledExecutionTime

triggerContextMonitor

private final java.lang.Object triggerContextMonitor

Constructor Detail

ReschedulingRunnable

public ReschedulingRunnable(java.lang.Runnable delegate,
                            Trigger trigger,
                            java.util.concurrent.ScheduledExecutorService executor,
                            ErrorHandler errorHandler)

Method Detail

schedule

public java.util.concurrent.ScheduledFuture<?> schedule()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class DelegatingErrorHandlingRunnable

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<java.lang.Object>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<java.lang.Object>

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<java.lang.Object>

get

public java.lang.Object get()
                     throws java.lang.InterruptedException,
                            java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<java.lang.Object>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public java.lang.Object get(long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException,
                            java.util.concurrent.ExecutionException,
                            java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<java.lang.Object>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

getDelay

public long getDelay(java.util.concurrent.TimeUnit unit)

Specified by:

getDelay in interface java.util.concurrent.Delayed

compareTo

public int compareTo(java.util.concurrent.Delayed other)

Specified by:

compareTo in interface java.lang.Comparable<java.util.concurrent.Delayed>