Package io.opentelemetry.context
Class ContextExecutorService
java.lang.Object
io.opentelemetry.context.ForwardingExecutorService
io.opentelemetry.context.ContextExecutorService
- All Implemented Interfaces:
AutoCloseable
,Executor
,ExecutorService
- Direct Known Subclasses:
ContextScheduledExecutorService
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) final Context
context()
void
invokeAll
(Collection<? extends Callable<T>> tasks) invokeAll
(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) <T> T
invokeAny
(Collection<? extends Callable<T>> tasks) <T> T
invokeAny
(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) Future
<?> <T> Future
<T> <T> Future
<T> Methods inherited from class io.opentelemetry.context.ForwardingExecutorService
awaitTermination, delegate, isShutdown, isTerminated, shutdown, shutdownNow, wrap
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.concurrent.ExecutorService
close
-
Field Details
-
context
-
-
Constructor Details
-
ContextExecutorService
ContextExecutorService(Context context, ExecutorService delegate)
-
-
Method Details
-
context
-
submit
-
submit
-
submit
-
invokeAll
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException - Throws:
InterruptedException
-
invokeAll
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException - Throws:
InterruptedException
-
invokeAny
public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException -
invokeAny
public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException -
execute
-