Package org.apache.druid.java.util.common.concurrent

Interface DecoratedExecutorService.Decorator

Enclosing class:

DecoratedExecutorService

public static interface DecoratedExecutorService.Decorator

Decorates tasks before they are submitted to an executor.

Method Summary

Modifier and Type	Method	Description
<T> Callable<T>	decorateCallable(Callable<T> callable)
Runnable	decorateRunnable(Runnable runnable)
default <T> Callable<T>	decorateScheduledCallable(Callable<T> callable, long delay, TimeUnit unit)	Decorates a callable that will be executed after an intended delay.
default Runnable	decorateScheduledRunnable(Runnable runnable, long delay, TimeUnit unit)	Decorates a runnable that will be executed after an intended delay.

Method Details

decorateCallable

<T> Callable<T> decorateCallable(Callable<T> callable)

decorateRunnable

Runnable decorateRunnable(Runnable runnable)

decorateScheduledCallable

default <T> Callable<T> decorateScheduledCallable(Callable<T> callable,
 long delay,
 TimeUnit unit)

Decorates a callable that will be executed after an intended delay. Used by DecoratedScheduledExecutorService for ScheduledExecutorService.schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit). Defaults to decorateCallable(java.util.concurrent.Callable<T>).

decorateScheduledRunnable

default Runnable decorateScheduledRunnable(Runnable runnable,
 long delay,
 TimeUnit unit)

Decorates a runnable that will be executed after an intended delay. Used by DecoratedScheduledExecutorService for ScheduledExecutorService.schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit). Defaults to decorateRunnable(java.lang.Runnable).