Class ForwardingExecutorService

java.lang.Object

io.opentelemetry.context.ForwardingExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

Direct Known Subclasses:

ContextExecutorService, CurrentContextExecutorService

abstract class ForwardingExecutorService
extends Object
implements ExecutorService

A ExecutorService that implements methods that don't need Context.

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	delegate

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ForwardingExecutorService(ExecutorService delegate)

Method Summary

Modifier and Type	Method	Description
final boolean	awaitTermination(long timeout, TimeUnit unit)
(package private) ExecutorService	delegate()
final boolean	isShutdown()
final boolean	isTerminated()
final void	shutdown()
final List<Runnable>	shutdownNow()
protected static <T> Collection<? extends Callable<T>>	wrap(Context context, Collection<? extends Callable<T>> tasks)

Methods inherited from class Object

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

Methods inherited from interface Executor

execute

Methods inherited from interface ExecutorService

close, invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Field Details

delegate

private final ExecutorService delegate

Constructor Details

ForwardingExecutorService

protected ForwardingExecutorService(ExecutorService delegate)

Method Details

delegate

ExecutorService delegate()

shutdown

public final void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

public final List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public final boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public final boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

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

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

wrap

protected static <T>
Collection<? extends Callable<T>> wrap(Context context,
 Collection<? extends Callable<T>> tasks)