org.apache.river.thread

Class ObservableFutureTask<T>

java.lang.Object

java.util.concurrent.FutureTask<T>

org.apache.river.thread.ObservableFutureTask<T>

All Implemented Interfaces:

Runnable, Future<T>, RunnableFuture<T>, FutureObserver.ObservableFuture<T>

public class ObservableFutureTask<T>
extends FutureTask<T>
implements FutureObserver.ObservableFuture<T>

Author:

peter

Field Summary

Fields

Modifier and Type	Field and Description
boolean	done
List<FutureObserver<T>>	listeners

Constructor Summary

Constructors

Constructor and Description
ObservableFutureTask(Callable<T> callable)
ObservableFutureTask(Runnable r, T result)

Method Summary

Modifier and Type	Method and Description
boolean	addObserver(FutureObserver<T> l) Adds FutureObserver's to this ObservableFuture.
protected void	done()

Methods inherited from class java.util.concurrent.FutureTask

cancel, get, get, isCancelled, isDone, run, runAndReset, set, setException

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Field Detail

listeners

public final List<FutureObserver<T>> listeners

done

public volatile boolean done

Constructor Detail

ObservableFutureTask

public ObservableFutureTask(Callable<T> callable)

ObservableFutureTask

public ObservableFutureTask(Runnable r,
                            T result)

Method Detail

done

protected void done()

Overrides:

done in class FutureTask<T>

addObserver

public boolean addObserver(FutureObserver<T> l)

Description copied from interface: FutureObserver.ObservableFuture

Adds FutureObserver's to this ObservableFuture.

Specified by:

addObserver in interface FutureObserver.ObservableFuture<T>

Parameters:

l - to observe this.

Returns:

true if observer was added, false otherwise.