Class CurrentContextExecutorService

java.lang.Object

io.opentelemetry.context.ForwardingExecutorService

io.opentelemetry.context.CurrentContextExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

Direct Known Subclasses:

CurrentContextScheduledExecutorService

class CurrentContextExecutorService
extends ForwardingExecutorService

Constructor Summary

Constructors

Constructor	Description
CurrentContextExecutorService(ExecutorService delegate)

Method Summary

Modifier and Type	Method	Description
void	execute(Runnable command)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	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<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Callable<T> task)

Methods inherited from class ForwardingExecutorService

awaitTermination, delegate, isShutdown, isTerminated, shutdown, shutdownNow, wrap

Methods inherited from class Object

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

Methods inherited from interface ExecutorService

close

Constructor Details

CurrentContextExecutorService

CurrentContextExecutorService(ExecutorService delegate)

Method Details

submit

public <T> Future<T> submit(Callable<T> task)

submit

public <T> Future<T> submit(Runnable task,
 T result)

submit

public Future<?> submit(Runnable task)

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

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
 long timeout,
 TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Throws:

InterruptedException

ExecutionException

TimeoutException

execute

public void execute(Runnable command)