public class DelegatingSecurityContextExecutorService extends DelegatingSecurityContextExecutor implements ExecutorService
ExecutorService which wraps each Runnable in a DelegatingSecurityContextRunnable and each
Callable in a DelegatingSecurityContextCallable.| Constructor and Description |
|---|
DelegatingSecurityContextExecutorService(ExecutorService delegate)
Creates a new
DelegatingSecurityContextExecutorService that uses the current SecurityContext from
the SecurityContextHolder. |
DelegatingSecurityContextExecutorService(ExecutorService delegateExecutorService,
SecurityContext securityContext)
Creates a new
DelegatingSecurityContextExecutorService that uses the specified SecurityContext. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
List |
invokeAll(Collection tasks) |
List |
invokeAll(Collection tasks,
long timeout,
TimeUnit unit) |
Object |
invokeAny(Collection tasks) |
Object |
invokeAny(Collection 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) |
protected <T> Callable<T> |
wrap(Callable<T> delegate) |
protected Runnable |
wrap(Runnable delegate) |
execute, getDelegateExecutorpublic DelegatingSecurityContextExecutorService(ExecutorService delegateExecutorService, SecurityContext securityContext)
DelegatingSecurityContextExecutorService that uses the specified SecurityContext.delegateExecutorService - the ExecutorService to delegate to. Cannot be null.securityContext - the SecurityContext to use for each DelegatingSecurityContextRunnable and
each DelegatingSecurityContextCallable.public DelegatingSecurityContextExecutorService(ExecutorService delegate)
DelegatingSecurityContextExecutorService that uses the current SecurityContext from
the SecurityContextHolder.delegateTaskExecutor - the TaskExecutor to delegate to. Cannot be null.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 List invokeAll(Collection tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic final List invokeAll(Collection tasks, long timeout, TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic final Object invokeAny(Collection tasks) throws InterruptedException, ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic final Object invokeAny(Collection tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutException