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

class ContextExecutorService
extends ForwardingExecutorService

Field Summary

Fields

Modifier and Type	Field	Description
private final Context	context

Constructor Summary

Constructors

Constructor	Description
ContextExecutorService(Context context, ExecutorService delegate)

Method Summary

Modifier and Type	Method	Description
(package private) final Context	context()
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 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

private final Context context

Constructor Details

ContextExecutorService

ContextExecutorService(Context context,
 ExecutorService delegate)

Method Details

context

final Context context()

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)