Package com.linkedin.alpini.base.registry.impl

Class ShutdownableExecutorServiceImpl<E extends ExecutorService>

java.lang.Object

java.util.concurrent.AbstractExecutorService

com.linkedin.alpini.base.registry.impl.ShutdownableExecutorServiceImpl<E>

All Implemented Interfaces:

ExecutorService, Shutdownable, ShutdownableExecutorService, ShutdownableResource, Executor, ExecutorService

Direct Known Subclasses:

ShutdownableScheduledExecutorServiceImpl

public class ShutdownableExecutorServiceImpl<E extends ExecutorService>
extends AbstractExecutorService
implements ShutdownableExecutorService

Field Summary

Fields

Modifier and Type	Field	Description
protected final E	_e

Constructor Summary

Constructors

Constructor	Description
ShutdownableExecutorServiceImpl(E executor)

Method Summary

Modifier and Type	Method	Description
final boolean	awaitTermination(long timeout, TimeUnit unit)
final void	execute(Runnable command)
final <T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
final <T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
final <T> T	invokeAny(Collection<? extends Callable<T>> tasks)
final <T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
final boolean	isShutdown()	Returns true if this resource has been shut down.
final boolean	isTerminated()	Returns true if the resource has completed shutting down.
void	shutdown()	Starts the shutdown process.
final List<Runnable>	shutdownNow()
final AsyncFuture<?>	submit(Runnable task)	Submits a Runnable task for execution and returns a Future representing that task.
final <T> AsyncFuture<T>	submit(Runnable task, T result)	Submits a Runnable task for execution and returns a Future representing that task.
final <T> AsyncFuture<T>	submit(Callable<T> task)	Submits a value-returning task for execution and returns a Future representing the pending results of the task.
final <T extends ExecutorService> T	unwrap(Class<T> clazz)	Returns an object that implements the given interface to allow access to non-standard methods, or standard methods not exposed by the proxy.
final void	waitForShutdown()	Waits for shutdown to complete
final void	waitForShutdown(long timeoutInMs)	Waits for shutdown to complete with a timeout

Methods inherited from class java.util.concurrent.AbstractExecutorService

newTaskFor, newTaskFor

Methods inherited from class java.lang.Object

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

Field Details

_e

@Nonnull
protected final E extends ExecutorService _e

Constructor Details

ShutdownableExecutorServiceImpl

public ShutdownableExecutorServiceImpl(@Nonnull
 E executor)

Method Details

execute

public final void execute(@Nonnull
 Runnable command)

Specified by:

execute in interface Executor

See Also:

• Executor.execute(Runnable)

shutdown

public void shutdown()

Description copied from interface: Shutdownable

Starts the shutdown process. It is recommended to perform the actual shutdown activity in a separate thread from the thread that calls shutdown

Specified by:

shutdown in interface ExecutorService

Specified by:

shutdown in interface Shutdownable

See Also:

• ExecutorService.shutdown()

shutdownNow

@Nonnull
public final List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

See Also:

• ExecutorService.shutdownNow()

isShutdown

public final boolean isShutdown()

Description copied from interface: ShutdownableResource

Returns true if this resource has been shut down.

Specified by:

isShutdown in interface ExecutorService

Specified by:

isShutdown in interface ShutdownableResource

Returns:

true if this resource has been shut down

See Also:

• ExecutorService.isShutdown()

isTerminated

public final boolean isTerminated()

Description copied from interface: ShutdownableResource

Returns true if the resource has completed shutting down. Note that isTerminated is never true unless shutdown was called first.

Specified by:

isTerminated in interface ExecutorService

Specified by:

isTerminated in interface ShutdownableResource

Returns:

true if the resource has completed shutting down.

See Also:

• ExecutorService.isTerminated()

waitForShutdown

public final void waitForShutdown()
                           throws InterruptedException,
IllegalStateException

Description copied from interface: Shutdownable

Waits for shutdown to complete

Specified by:

waitForShutdown in interface Shutdownable

Throws:

InterruptedException - when the wait is interrupted

IllegalStateException - when the method is invoked when the shutdown has yet to be started

See Also:

• Shutdownable.waitForShutdown()

waitForShutdown

public final void waitForShutdown(long timeoutInMs)
                           throws InterruptedException,
IllegalStateException,
TimeoutException

Description copied from interface: Shutdownable

Waits for shutdown to complete with a timeout

Specified by:

waitForShutdown in interface Shutdownable

Parameters:

timeoutInMs - number of milliseconds to wait before throwing TimeoutException

Throws:

InterruptedException - when the wait is interrupted

IllegalStateException - when the method is invoked when the shutdown has yet to be started

TimeoutException - when the operation times out

See Also:

• Shutdownable.waitForShutdown(long)

awaitTermination

public final boolean awaitTermination(long timeout,
 @Nonnull
 TimeUnit unit)
                               throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

See Also:

• ExecutorService.awaitTermination(long, java.util.concurrent.TimeUnit)

submit

@Nonnull
public final AsyncFuture<?> submit(@Nonnull
 Runnable task)

Description copied from interface: ExecutorService

Submits a Runnable task for execution and returns a Future representing that task. The Future's get method will return null upon successful completion.

Specified by:

submit in interface ExecutorService

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

Parameters:

task - the task to submit

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Runnable)

submit

@Nonnull
public final <T> AsyncFuture<T> submit(@Nonnull
 Callable<T> task)

Description copied from interface: ExecutorService

Submits a value-returning task for execution and returns a Future representing the pending results of the task. The Future's get method will return the task's result upon successful completion.

If you would like to immediately block waiting for a task, you can use constructions of the form result = exec.submit(aCallable).get();

Note: The Executors class includes a set of methods that can convert some other common closure-like objects, for example, PrivilegedAction to Callable form so they can be submitted.

Specified by:

submit in interface ExecutorService

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

Type Parameters:

T - the type of the task's result

Parameters:

task - the task to submit

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Callable)

submit

@Nonnull
public final <T> AsyncFuture<T> submit(@Nonnull
 Runnable task,
 T result)

Description copied from interface: ExecutorService

Submits a Runnable task for execution and returns a Future representing that task. The Future's get method will return the given result upon successful completion.

Specified by:

submit in interface ExecutorService

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

Type Parameters:

T - the type of the result

Parameters:

task - the task to submit

result - the result to return

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Runnable, Object)

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Overrides:

invokeAll in class AbstractExecutorService

Throws:

InterruptedException

See Also:

• ExecutorService.invokeAll(Collection)

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Overrides:

invokeAll in class AbstractExecutorService

Throws:

InterruptedException

See Also:

• ExecutorService.invokeAll(Collection, long, TimeUnit)

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Overrides:

invokeAny in class AbstractExecutorService

Throws:

InterruptedException

ExecutionException

See Also:

• ExecutorService.invokeAny(Collection)

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Overrides:

invokeAny in class AbstractExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

See Also:

• ExecutorService.invokeAny(Collection, long, TimeUnit)

unwrap

public final <T extends ExecutorService> T unwrap(Class<T> clazz)

Description copied from interface: ShutdownableExecutorService

Returns an object that implements the given interface to allow access to non-standard methods, or standard methods not exposed by the proxy.

Specified by:

unwrap in interface ShutdownableExecutorService

Parameters:

clazz - A Class defining an interface that the result must implement.

Returns:

an object that implements the interface. May be a proxy for the actual implementing object.

See Also:

• ShutdownableExecutorService.unwrap(Class)