Package de.aristaflow.adept2.util.threading

Class LoggingScheduledFuture<V>

java.lang.Object

de.aristaflow.adept2.util.threading.LoggingFuture<V>

de.aristaflow.adept2.util.threading.LoggingScheduledFuture<V>

Type Parameters:

V - The result type returned by this Future's get method.

All Implemented Interfaces:

Comparable<Delayed>, Runnable, Delayed, Future<V>, RunnableFuture<V>, RunnableScheduledFuture<V>, ScheduledFuture<V>

public class LoggingScheduledFuture<V>
extends LoggingFuture<V>
implements RunnableScheduledFuture<V>

A scheduled future that wraps another future and logs all occurred exceptions and the result for information purpose if no one was interested in it.

Author:

Ulrich Kreher

Nested Class Summary

Nested classes/interfaces inherited from class de.aristaflow.adept2.util.threading.LoggingFuture

LoggingFuture.IgnoredResultLogger

Field Summary

Fields inherited from class de.aristaflow.adept2.util.threading.LoggingFuture

cleanup, logger, resultRelevant

Constructor Summary

Constructors

Constructor	Description
LoggingScheduledFuture(RunnableScheduledFuture<V> future, boolean resultRelevant, Logger logger)	Creates a new future wrapping the designated RunnableScheduledFuture logging the outcome of the future if no one has retrieved it.

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
int	compareTo(Delayed o)
long	getDelay(TimeUnit unit)
protected RunnableScheduledFuture<V>	getWrappedFutureRunnable()	Gets the wrapped future runnable.
boolean	isPeriodic()

Methods inherited from class de.aristaflow.adept2.util.threading.LoggingFuture

equals, get, get, hashCode, isCancelled, isDone, run

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.concurrent.Future

get, get, isCancelled, isDone

Methods inherited from interface java.util.concurrent.RunnableFuture

run

Constructor Details

LoggingScheduledFuture

public LoggingScheduledFuture(RunnableScheduledFuture<V> future,
 boolean resultRelevant,
 Logger logger)

Creates a new future wrapping the designated RunnableScheduledFuture logging the outcome of the future if no one has retrieved it.

Parameters:

future - The RunnableScheduledFuture which to wrap.

resultRelevant - Whether the result of the future is relevant and therefore it should be logged if it is not retrieved.

logger - The logger for logging unhandled results, Exception, RuntimeException or Error.

Method Details

getWrappedFutureRunnable

protected RunnableScheduledFuture<V> getWrappedFutureRunnable()

Description copied from class: LoggingFuture

Gets the wrapped future runnable. This is useful for subclasses requiring a more specific object.

Overrides:

getWrappedFutureRunnable in class LoggingFuture<V>

Returns:

The wrapped future runnable.

getDelay

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

isPeriodic

public boolean isPeriodic()

Specified by:

isPeriodic in interface RunnableScheduledFuture<V>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

Overrides:

cancel in class LoggingFuture<V>

compareTo

public int compareTo(Delayed o)

Specified by:

compareTo in interface Comparable<V>