de.unkrig.commons.util.concurrent

Class SquadExecutor<T>

java.lang.Object

de.unkrig.commons.util.concurrent.SquadExecutor<T>

Type Parameters:

T - The futures' result type

All Implemented Interfaces:

Executor

public class SquadExecutor<T>
extends Object
implements Executor

An Executor which executes tasks through a delegate ExecutorService. The awaitCompletion() methods waits until all tasks of the squad are complete.

Constructor Summary

Constructors

Constructor and Description
SquadExecutor(ExecutorService delegate)

Method Summary

Modifier and Type	Method and Description
List<Future<T>>	awaitCompletion() Returns when all tasks that were previously submitted with submit(Callable), submit(Runnable, Object), submit(Runnable, Object) and execute(Runnable) have completed.
List<Future<T>>	awaitCompletion(long timeout, TimeUnit unit) Returns when all tasks that were previously submitted with submit(Callable), submit(Runnable, Object), submit(Runnable, Object) and execute(Runnable) have completed, or when then timeout expires.
void	execute(Runnable command)
Future<T>	submit(Callable<T> task) Submits a value-returning task for execution.
Future<T>	submit(Runnable task) Submits a Runnable task for execution.
Future<T>	submit(Runnable task, T result) Submits a Runnable task for execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

SquadExecutor

public SquadExecutor(ExecutorService delegate)

See Also:

SquadExecutor

Method Detail

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

submit

public Future<T> submit(@Nullable
                        Runnable task)

Submits a Runnable task for execution.

Parameters:

task - The task to submit

Returns:

A future representing pending completion of the task

submit

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

Submits a Runnable task for execution.

Parameters:

task - The task to submit

result - The result to return

Returns:

A future representing pending completion of the task

submit

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

Submits a value-returning task for execution.

Parameters:

task - The task to submit

Returns:

A future representing pending completion of the task

awaitCompletion

public List<Future<T>> awaitCompletion()
                                throws InterruptedException,
                                       ExecutionException,
                                       CancellationException

Returns when all tasks that were previously submitted with submit(Callable), submit(Runnable, Object), submit(Runnable, Object) and execute(Runnable) have completed.

Returns:

The futures of the tasks

Throws:

CancellationException - One of the tasks was cancelled

ExecutionException - One of the tasks threw an exception

InterruptedException - The current thread was interrupted while waiting

awaitCompletion

public List<Future<T>> awaitCompletion(long timeout,
                                       TimeUnit unit)
                                throws CancellationException,
                                       ExecutionException,
                                       InterruptedException

Returns when all tasks that were previously submitted with submit(Callable), submit(Runnable, Object), submit(Runnable, Object) and execute(Runnable) have completed, or when then timeout expires.

Returns:

The futures of the tasks

Throws:

CancellationException - One of the tasks was cancelled

ExecutionException - One of the tasks threw an exception

InterruptedException - The current thread was interrupted while waiting