Package hec.util.concurrent

Class AwaitableFutureTask<T>

java.lang.Object

java.util.concurrent.FutureTask<T>

hec.util.concurrent.AwaitableFutureTask<T>

All Implemented Interfaces:

Runnable, Future<T>, RunnableFuture<T>

Direct Known Subclasses:

MapScaleImage

public class AwaitableFutureTask<T>
extends FutureTask<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected final CountDownLatch	actuallyFinishedLatch
protected final AtomicBoolean	wasStarted

Constructor Summary

Constructors

Constructor	Description
AwaitableFutureTask(Runnable runnable)
AwaitableFutureTask(Callable<T> callable)

Method Summary

Modifier and Type	Method	Description
void	awaitActualCompletion()
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
boolean	isFinished()
boolean	isRunning()
boolean	wasStarted()

Methods inherited from class java.util.concurrent.FutureTask

done, get, isCancelled, isDone, run, runAndReset, set, setException, toString

Methods inherited from class java.lang.Object

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

Field Details

wasStarted

protected final AtomicBoolean wasStarted

actuallyFinishedLatch

protected final CountDownLatch actuallyFinishedLatch

Constructor Details

AwaitableFutureTask

public AwaitableFutureTask(Runnable runnable)

AwaitableFutureTask

public AwaitableFutureTask(Callable<T> callable)

Method Details

awaitActualCompletion

public void awaitActualCompletion()
                           throws InterruptedException

Throws:

InterruptedException

wasStarted

public boolean wasStarted()

isRunning

public boolean isRunning()

isFinished

public boolean isFinished()

get

public T get()
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Overrides:

get in class FutureTask<T>

Throws:

InterruptedException

ExecutionException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class FutureTask<T>