com.hazelcast.scheduledexecutor.impl

Class ScheduledFutureProxy<V>

java.lang.Object

com.hazelcast.scheduledexecutor.impl.ScheduledFutureProxy<V>

All Implemented Interfaces:

HazelcastInstanceAware, IScheduledFuture<V>, Comparable<Delayed>, Delayed, Future<V>, ScheduledFuture<V>

public final class ScheduledFutureProxy<V>
extends Object
implements IScheduledFuture<V>, HazelcastInstanceAware

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning) Attempts to cancel further scheduling of this task.
int	compareTo(Delayed o)
void	dispose() Used to destroy the instance of the IScheduledFuture in the scheduled executor.
V	get()
V	get(long timeout, TimeUnit unit)
long	getDelay(TimeUnit unit)
ScheduledTaskHandler	getHandler() Returns the scheduled future resource handler.
ScheduledTaskStatistics	getStats() Returns the statistics and time measurement info of the execution of this scheduled future in the IScheduledExecutorService it was scheduled.
boolean	isCancelled()
boolean	isDone()
void	setHazelcastInstance(HazelcastInstance hazelcastInstance) Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Methods inherited from class java.lang.Object

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

Method Detail

setHazelcastInstance

public void setHazelcastInstance(HazelcastInstance hazelcastInstance)

Description copied from interface: HazelcastInstanceAware

Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Specified by:

setHazelcastInstance in interface HazelcastInstanceAware

Parameters:

hazelcastInstance - the HazelcastInstance reference

getHandler

public ScheduledTaskHandler getHandler()

Description copied from interface: IScheduledFuture

Returns the scheduled future resource handler. Can be used to re-acquire control of the IScheduledFuture using the IScheduledExecutorService.getScheduledFuture(ScheduledTaskHandler)

Specified by:

getHandler in interface IScheduledFuture<V>

Returns:

An instance of ScheduledTaskHandler, a resource handler for this scheduled future.

getStats

public ScheduledTaskStatistics getStats()

Description copied from interface: IScheduledFuture

Returns the statistics and time measurement info of the execution of this scheduled future in the IScheduledExecutorService it was scheduled.

Specified by:

getStats in interface IScheduledFuture<V>

Returns:

An instance of ScheduledTaskStatistics, holding all stas and measurements

getDelay

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

compareTo

public int compareTo(Delayed o)

Specified by:

compareTo in interface Comparable<Delayed>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Description copied from interface: IScheduledFuture

Attempts to cancel further scheduling of this task. This attempt will fail if the task has already completed, has already been cancelled, or could not be cancelled for some other reason. If successful, and this task has not started when cancel is called, this task should never run.

Warning: This cancel will not attempt to interrupt the running thread if the task is already in progress, will just cancel further scheduling.

After this method returns, subsequent calls to Future.isDone() will always return true. Subsequent calls to Future.isCancelled() will always return true if this method returned true.

Specified by:

cancel in interface IScheduledFuture<V>

Specified by:

cancel in interface Future<V>

Parameters:

mayInterruptIfRunning - is throwing UnsupportedOperationException

Returns:

false if the task could not be cancelled, typically because it has already completed normally; {@code true

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<V>

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

get

public V get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

dispose

public void dispose()

Description copied from interface: IScheduledFuture

Used to destroy the instance of the IScheduledFuture in the scheduled executor. Once the instance is destroyed, any subsequent action on the IScheduledFuture will fail with an IllegalStateException Attempting to re-create the IScheduledFuture from the IScheduledExecutorService.getScheduledFuture(ScheduledTaskHandler) using the IScheduledFuture.getHandler() will succeed, but any subsequent access on that new future, will also fail with StaleTaskException

Specified by:

dispose in interface IScheduledFuture<V>