Package io.micronaut.scheduling.instrument

Interface InstrumentedExecutorService

All Superinterfaces:

Executor, ExecutorService, InstrumentedExecutor, RunnableInstrumenter

All Known Subinterfaces:

InstrumentedScheduledExecutorService

All Known Implementing Classes:

ContextPropagatingExecutorService, ContextPropagatingScheduledExecutorService

public interface InstrumentedExecutorService
extends ExecutorService, InstrumentedExecutor

An ExecutorService that has been instrumented to allow for propagation of thread state and other instrumentation related tasks.

Since:

1.0

Author:

Graeme Rocher

Method Summary

Modifier and Type	Method	Description
default boolean	awaitTermination(long timeout, @NonNull TimeUnit unit)
ExecutorService	getTarget()	Implementors can override to specify the target ExecutorService.
default <T> Callable<T>	instrument(Callable<T> task)	Instruments the given callable task.
default <T> @NonNull List<Future<T>>	invokeAll(@NonNull Collection<? extends Callable<T>> tasks)
default <T> @NonNull List<Future<T>>	invokeAll(@NonNull Collection<? extends Callable<T>> tasks, long timeout, @NonNull TimeUnit unit)
default <T> T	invokeAny(@NonNull Collection<? extends Callable<T>> tasks)
default <T> T	invokeAny(@NonNull Collection<? extends Callable<T>> tasks, long timeout, @NonNull TimeUnit unit)
default boolean	isShutdown()
default boolean	isTerminated()
default void	shutdown()
default List<Runnable>	shutdownNow()
default @NonNull Future<?>	submit(@NonNull Runnable task)
default <T> @NonNull Future<T>	submit(@NonNull Runnable task, T result)
default <T> @NonNull Future<T>	submit(@NonNull Callable<T> task)

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedExecutor

execute

Methods inherited from interface io.micronaut.scheduling.instrument.RunnableInstrumenter

instrument

Method Details

getTarget

ExecutorService getTarget()

Implementors can override to specify the target ExecutorService.

Specified by:

getTarget in interface InstrumentedExecutor

Returns:

The target ExecutorService

instrument

default <T> Callable<T> instrument(Callable<T> task)

Instruments the given callable task.

Type Parameters:

T - The generic return type

Parameters:

task - the task to instrument

Returns:

The callable

shutdown

default void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

default List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

default boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

default boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

default boolean awaitTermination(long timeout,
 @NonNull
 @NonNull TimeUnit unit)
                          throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

submit

@NonNull
default <T> @NonNull Future<T> submit(@NonNull
 @NonNull Callable<T> task)

Specified by:

submit in interface ExecutorService

submit

@NonNull
default <T> @NonNull Future<T> submit(@NonNull
 @NonNull Runnable task,
 T result)

Specified by:

submit in interface ExecutorService

submit

@NonNull
default @NonNull Future<?> submit(@NonNull
 @NonNull Runnable task)

Specified by:

submit in interface ExecutorService

invokeAll

@NonNull
default <T> @NonNull List<Future<T>> invokeAll(@NonNull
 @NonNull Collection<? extends Callable<T>> tasks)
                                        throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

@NonNull
default <T> T invokeAny(@NonNull
 @NonNull Collection<? extends Callable<T>> tasks)
                 throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException