com.bluegosling.concurrent.executors

Interface InterceptingExecutorService.Interceptor

Enclosing class:

InterceptingExecutorService

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface InterceptingExecutorService.Interceptor

An interceptor for tasks. Interceptor implementations can perform actions before and after running the task. Interceptors are expected to invoke task.call(), unless they are choosing to block execution of the given task. Interceptors can also modify the result of the call by returning a value other than what the task produced.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	InterceptingExecutorService.Interceptor.ListBuilder Builds a list of interceptors.

Method Summary

Modifier and Type	Method and Description
<T> T	intercept(ExecutorService delegate, Callable<T> task) Intercepts the given task.
static InterceptingExecutorService.Interceptor.ListBuilder	newList() Returns a new builder, for building a list of interceptors from both interceptor and decorator instances.

Method Detail

intercept

<T> T intercept(ExecutorService delegate,
                Callable<T> task)
         throws Exception

Intercepts the given task. Implementations should call task.run() to proceed to the next interceptor in the chain and run the task.

Parameters:

delegate - the underlying executor that is executing the task

task - the task to run, which may be a wrapper that invokes subsequent interceptors

Returns:

the result of the task

Throws:

Exception

newList

static InterceptingExecutorService.Interceptor.ListBuilder newList()

Returns a new builder, for building a list of interceptors from both interceptor and decorator instances.

Returns:

a new list builder