Package ubic.gemma.cli.batch

Class AbstractDelegatingExecutorService

java.lang.Object

ubic.gemma.cli.batch.AbstractDelegatingExecutorService

All Implemented Interfaces:

Executor, ExecutorService

Direct Known Subclasses:

BatchTaskExecutorService

public abstract class AbstractDelegatingExecutorService
extends Object
implements ExecutorService

A delegating executor service inspired by DelegatingSecurityContextExecutorService.

Author:

poirigui

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractDelegatingExecutorService(ExecutorService delegate)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long l, TimeUnit timeUnit)
void	execute(Runnable runnable)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> collection)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> collection, long l, TimeUnit timeUnit)
<T> T	invokeAny(Collection<? extends Callable<T>> collection)
<T> T	invokeAny(Collection<? extends Callable<T>> collection, long l, TimeUnit timeUnit)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable runnable)
<T> Future<T>	submit(Runnable runnable, T t)
<T> Future<T>	submit(Callable<T> callable)
protected abstract Runnable	wrap(Runnable runnable)
protected abstract <T> Callable<T>	wrap(Callable<T> callable)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDelegatingExecutorService

protected AbstractDelegatingExecutorService(ExecutorService delegate)

Method Detail

wrap

protected abstract Runnable wrap(Runnable runnable)

wrap

protected abstract <T> Callable<T> wrap(Callable<T> callable)

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@Nonnull
public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long l,
                                TimeUnit timeUnit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

submit

@Nonnull
public <T> Future<T> submit(Callable<T> callable)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public <T> Future<T> submit(Runnable runnable,
                            T t)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public Future<?> submit(Runnable runnable)

Specified by:

submit in interface ExecutorService

invokeAll

@Nonnull
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> collection)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

@Nonnull
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> collection,
                                     long l,
                                     TimeUnit timeUnit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

@Nonnull
public <T> T invokeAny(Collection<? extends Callable<T>> collection)
                throws InterruptedException,
                       ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> collection,
                       long l,
                       TimeUnit timeUnit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor