org.jactr.core.concurrent

Class ListenableFuture<C>

java.lang.Object

java.util.concurrent.FutureTask<C>

org.jactr.core.concurrent.ListenableFuture<C>

All Implemented Interfaces:

java.lang.Runnable, java.util.concurrent.Future<C>, java.util.concurrent.RunnableFuture<C>

public class ListenableFuture<C>
extends java.util.concurrent.FutureTask<C>

Constructor Summary

Constructors

Constructor and Description
ListenableFuture(java.lang.Runnable runner)

Method Summary

Modifier and Type	Method and Description
void	add(IListenableFutureListener<C> listener)
boolean	cancel(boolean mayInterrupt)
void	remove(IListenableFutureListener<C> listener)
protected void	set(C result)
void	set(C result, java.lang.Throwable thrown) set the result or exception on this future, releasing any blocking FutureTask.get() calls
protected void	setException(java.lang.Throwable thrown)

Methods inherited from class java.util.concurrent.FutureTask

done, get, get, isCancelled, isDone, run, runAndReset

Methods inherited from class java.lang.Object

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

Constructor Detail

ListenableFuture

public ListenableFuture(java.lang.Runnable runner)

Method Detail

set

public void set(C result,
                java.lang.Throwable thrown)

set the result or exception on this future, releasing any blocking FutureTask.get() calls

Parameters:

result -

thrown -

setException

protected void setException(java.lang.Throwable thrown)

Overrides:

setException in class java.util.concurrent.FutureTask<C>

set

protected void set(C result)

Overrides:

set in class java.util.concurrent.FutureTask<C>

cancel

public boolean cancel(boolean mayInterrupt)

Specified by:

cancel in interface java.util.concurrent.Future<C>

Overrides:

cancel in class java.util.concurrent.FutureTask<C>

add

public void add(IListenableFutureListener<C> listener)

remove

public void remove(IListenableFutureListener<C> listener)