Package io.opentelemetry.context
Class ForwardingExecutorService
java.lang.Object
io.opentelemetry.context.ForwardingExecutorService
- All Implemented Interfaces:
AutoCloseable
,Executor
,ExecutorService
- Direct Known Subclasses:
ContextExecutorService
,CurrentContextExecutorService
A
ExecutorService
that implements methods that don't need Context
.-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal boolean
awaitTermination
(long timeout, TimeUnit unit) (package private) ExecutorService
delegate()
final boolean
final boolean
final void
shutdown()
protected static <T> Collection
<? extends Callable<T>> wrap
(Context context, Collection<? extends Callable<T>> tasks)
-
Field Details
-
delegate
-
-
Constructor Details
-
ForwardingExecutorService
-
-
Method Details
-
delegate
ExecutorService delegate() -
shutdown
public final void shutdown()- Specified by:
shutdown
in interfaceExecutorService
-
shutdownNow
- Specified by:
shutdownNow
in interfaceExecutorService
-
isShutdown
public final boolean isShutdown()- Specified by:
isShutdown
in interfaceExecutorService
-
isTerminated
public final boolean isTerminated()- Specified by:
isTerminated
in interfaceExecutorService
-
awaitTermination
- Specified by:
awaitTermination
in interfaceExecutorService
- Throws:
InterruptedException
-
wrap
protected static <T> Collection<? extends Callable<T>> wrap(Context context, Collection<? extends Callable<T>> tasks)
-