Package org.jgroups.util

Class HashedTimingWheel.MyTask

java.lang.Object

org.jgroups.util.HashedTimingWheel.MyTask

All Implemented Interfaces:

Runnable, Future

Enclosing class:

HashedTimingWheel

protected static class HashedTimingWheel.MyTask
extends Object
implements Future, Runnable

Simple task wrapper, always executed by at most 1 thread.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	cancelled
protected boolean	done
protected HashedTimingWheel.MyTask	next
protected int	round
protected final Runnable	task

Constructor Summary

Constructors

Constructor	Description
MyTask(Runnable task, int round)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
Object	get()
Object	get(long timeout, TimeUnit unit)
int	getAndDecrementRound()
int	getRound()
boolean	isCancelled()
boolean	isDone()
void	run()
void	setRound(int round)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Future

exceptionNow, resultNow, state

Field Details

task

protected final Runnable task

cancelled

protected volatile boolean cancelled

done

protected volatile boolean done

next

protected HashedTimingWheel.MyTask next

round

protected int round

Constructor Details

MyTask

public MyTask(Runnable task,
 int round)

Method Details

getRound

public int getRound()

getAndDecrementRound

public int getAndDecrementRound()

setRound

public void setRound(int round)

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