Class AbstractExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

All Implemented Interfaces:

Executor, ExecutorService

public abstract class AbstractExecutorService
extends Object
implements ExecutorService

The ExecutorService methods that need nothing but execute: a subclass provides execution and the life cycle, and gets submit, invokeAll and invokeAny from here.

Constructor Summary

Constructors

Constructor	Description
AbstractExecutorService()

Method Summary

Modifier and Type	Method	Description
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)	Runs every task and answers their futures, all of them done.
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)	Runs every task and answers their futures once all are done or the time is up; the ones not done by then are cancelled.
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)	The result of one of the tasks that completed without failing; the others are cancelled.
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)	As ExecutorService.invokeAny(Collection), giving up with a TimeoutException when no task has succeeded in time.
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable)
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Callable<T> task)

Methods inherited from class Object

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

Methods inherited from interface Executor

execute

Methods inherited from interface ExecutorService

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

Constructor Details

AbstractExecutorService

public AbstractExecutorService()

Method Details

newTaskFor

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

newTaskFor

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

submit

public Future<?> submit(Runnable task)

Specified by:

submit in interface ExecutorService

submit

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

Specified by:

submit in interface ExecutorService

submit

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

Specified by:

submit in interface ExecutorService

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Description copied from interface: ExecutorService

Runs every task and answers their futures, all of them done.

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                              throws InterruptedException

Description copied from interface: ExecutorService

Runs every task and answers their futures once all are done or the time is up; the ones not done by then are cancelled.

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
ExecutionException

Description copied from interface: ExecutorService

The result of one of the tasks that completed without failing; the others are cancelled.

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Description copied from interface: ExecutorService

As ExecutorService.invokeAny(Collection), giving up with a TimeoutException when no task has succeeded in time.

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException