public class ContextPropagatingExecutorService extends Object implements ExecutorService
| Constructor and Description |
|---|
ContextPropagatingExecutorService(ExecutorService wrapped) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
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) |
boolean |
isShutdown() |
boolean |
isTerminated() |
void |
shutdown() |
List<Runnable> |
shutdownNow() |
<T> Future<T> |
submit(Callable<T> task) |
Future<?> |
submit(Runnable task) |
<T> Future<T> |
submit(Runnable task,
T result) |
String |
toString() |
public ContextPropagatingExecutorService(ExecutorService wrapped)
public final void shutdown()
shutdown in interface ExecutorServicepublic final List<Runnable> shutdownNow()
shutdownNow in interface ExecutorServicepublic final boolean isShutdown()
isShutdown in interface ExecutorServicepublic final boolean isTerminated()
isTerminated in interface ExecutorServicepublic final boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic final <T> Future<T> submit(Callable<T> task)
submit in interface ExecutorServicepublic final <T> Future<T> submit(Runnable task, T result)
submit in interface ExecutorServicepublic final Future<?> submit(Runnable task)
submit in interface ExecutorServicepublic final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic final <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic final <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic final <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutExceptionCopyright © 2018 SPF4J. All rights reserved.