Class TimeScheduler3.Task

java.lang.Object

org.jgroups.util.TimeScheduler3.Task

All Implemented Interfaces:

Comparable<Delayed>, Runnable, Delayed, Future

Direct Known Subclasses:

TimeScheduler3.RecurringTask

Enclosing class:

TimeScheduler3

public static class TimeScheduler3.Task
extends Object
implements Runnable, Delayed, Future

Since:

3.3

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	can_block
protected boolean	cancelled
protected long	creation_time
protected long	delay
protected boolean	done
protected final Runnable	runnable

Constructor Summary

Constructors

Constructor	Description
Task(Runnable runnable, boolean can_block)
Task(Runnable runnable, long initial_delay, TimeUnit unit, boolean can_block)

Method Summary

Modifier and Type	Method	Description
boolean	canBlock()
boolean	cancel(boolean mayInterruptIfRunning)
int	compareTo(Delayed o)
Object	get()
Object	get(long timeout, TimeUnit unit)
long	getDelay(TimeUnit unit)
Runnable	getRunnable()
boolean	isCancelled()
boolean	isDone()
void	run()
String	toString()

Methods inherited from class Object

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

Methods inherited from interface Future

exceptionNow, resultNow, state

Field Details

runnable

protected final Runnable runnable

creation_time

protected long creation_time

delay

protected long delay

cancelled

protected volatile boolean cancelled

done

protected volatile boolean done

can_block

protected final boolean can_block

Constructor Details

Task

public Task(Runnable runnable,
 boolean can_block)

Task

public Task(Runnable runnable,
 long initial_delay,
 TimeUnit unit,
 boolean can_block)

Method Details

getRunnable

public Runnable getRunnable()

canBlock

public boolean canBlock()

compareTo

public int compareTo(Delayed o)

Specified by:

compareTo in interface Comparable<Delayed>

getDelay

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future

isDone

public boolean isDone()

Specified by:

isDone in interface Future

get

public Object get()
           throws InterruptedException,
ExecutionException

Specified by:

get in interface Future

Throws:

InterruptedException

ExecutionException

get

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

Specified by:

get in interface Future

Throws:

InterruptedException

ExecutionException

TimeoutException

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class Object