public class ThreadedExecutorService extends java.lang.Object implements ExecutorService
Modifier and Type | Class and Description |
---|---|
private static class |
ThreadedExecutorService.ContextualCallable<T> |
static class |
ThreadedExecutorService.ContextualStateSnapshot |
Modifier and Type | Field and Description |
---|---|
private Injector |
injector |
private ManagerImpl |
manager |
private java.util.concurrent.ExecutorService |
service |
Constructor and Description |
---|
ThreadedExecutorService(ManagerImpl manager) |
Modifier and Type | Method and Description |
---|---|
ContextSnapshot |
createSnapshotContext()
Create a snapshot of the current active Contexts.
|
private java.util.concurrent.ExecutorService |
executor() |
<T> java.util.concurrent.Future<T> |
submit(java.util.concurrent.Callable<T> task)
Submits a value-returning task for execution and returns a
Future representing the pending results of the task.
|
private <T> java.util.concurrent.Callable<T> |
wrap(java.util.concurrent.Callable<T> callable) |
private java.util.concurrent.ExecutorService service
private ManagerImpl manager
private Injector injector
public ThreadedExecutorService(ManagerImpl manager)
public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)
ExecutorService
submit
in interface ExecutorService
task
- the task to submitpublic ContextSnapshot createSnapshotContext()
ExecutorService
createSnapshotContext
in interface ExecutorService
private java.util.concurrent.ExecutorService executor()
private <T> java.util.concurrent.Callable<T> wrap(java.util.concurrent.Callable<T> callable)