org.limewire.concurrent
Class AbstractListeningExecutorService

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      org.limewire.concurrent.AbstractListeningExecutorService

All Implemented Interfaces:

Executor, ExecutorService

Direct Known Subclasses:

SimpleTimer

public abstract class AbstractListeningExecutorService
extends AbstractExecutorService

An extension to AbstractExecutorService that uses ListeningFuture.

Constructor Summary

AbstractListeningExecutorService()

Method Summary

protected <T> RunnableListeningFuture<T>	newTaskFor(Callable<T> callable)
protected <T> RunnableListeningFuture<T>	newTaskFor(Runnable runnable, T value)
<T> ListeningFuture<T>	submit(Callable<T> task)
ListeningFuture<?>	submit(Runnable task)
<T> ListeningFuture<T>	submit(Runnable task, T result)

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

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.ExecutorService

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

Methods inherited from interface java.util.concurrent.Executor

execute

Constructor Detail

AbstractListeningExecutorService

public AbstractListeningExecutorService()

Method Detail

newTaskFor

protected <T> RunnableListeningFuture<T> newTaskFor(Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableListeningFuture<T> newTaskFor(Runnable runnable,
                                                    T value)

Overrides:

newTaskFor in class AbstractExecutorService

submit

public <T> ListeningFuture<T> submit(Callable<T> task)

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

public ListeningFuture<?> submit(Runnable task)

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

public <T> ListeningFuture<T> submit(Runnable task,
                                     T result)

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService