Package io.opentelemetry.context
Class CurrentContextExecutorService
java.lang.Object
io.opentelemetry.context.ForwardingExecutorService
io.opentelemetry.context.CurrentContextExecutorService
- All Implemented Interfaces:
AutoCloseable
,Executor
,ExecutorService
- Direct Known Subclasses:
CurrentContextScheduledExecutorService
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
-
Constructor Details
-
CurrentContextExecutorService
CurrentContextExecutorService(ExecutorService delegate)
-
-
Method Details
-
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
-