Package io.opentelemetry.context
Class ForwardingExecutorService
- java.lang.Object
-
- io.opentelemetry.context.ForwardingExecutorService
-
- All Implemented Interfaces:
java.util.concurrent.Executor
,java.util.concurrent.ExecutorService
- Direct Known Subclasses:
ContextExecutorService
,CurrentContextExecutorService
abstract class ForwardingExecutorService extends java.lang.Object implements java.util.concurrent.ExecutorService
AExecutorService
that implements methods that don't needContext
.
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ExecutorService
delegate
-
Constructor Summary
Constructors Modifier Constructor Description protected
ForwardingExecutorService(java.util.concurrent.ExecutorService delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
(package private) java.util.concurrent.ExecutorService
delegate()
boolean
isShutdown()
boolean
isTerminated()
void
shutdown()
java.util.List<java.lang.Runnable>
shutdownNow()
protected static <T> java.util.Collection<? extends java.util.concurrent.Callable<T>>
wrap(Context context, java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
-
-
-
Method Detail
-
delegate
java.util.concurrent.ExecutorService delegate()
-
shutdown
public final void shutdown()
- Specified by:
shutdown
in interfacejava.util.concurrent.ExecutorService
-
shutdownNow
public final java.util.List<java.lang.Runnable> shutdownNow()
- Specified by:
shutdownNow
in interfacejava.util.concurrent.ExecutorService
-
isShutdown
public final boolean isShutdown()
- Specified by:
isShutdown
in interfacejava.util.concurrent.ExecutorService
-
isTerminated
public final boolean isTerminated()
- Specified by:
isTerminated
in interfacejava.util.concurrent.ExecutorService
-
awaitTermination
public final boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
- Specified by:
awaitTermination
in interfacejava.util.concurrent.ExecutorService
- Throws:
java.lang.InterruptedException
-
wrap
protected static <T> java.util.Collection<? extends java.util.concurrent.Callable<T>> wrap(Context context, java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
-
-