private static class ConcurrentTaskExecutor.ManagedTaskExecutorAdapter extends TaskExecutorAdapter
SchedulingAwareRunnable
and an identity name based on the task's
toString()
representation.TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE
Constructor and Description |
---|
ManagedTaskExecutorAdapter(java.util.concurrent.Executor concurrentExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
execute(java.lang.Runnable task)
Delegates to the specified JDK concurrent executor.
|
<T> java.util.concurrent.Future<T> |
submit(java.util.concurrent.Callable<T> task)
Submit a Callable task for execution, receiving a Future representing that task.
|
java.util.concurrent.Future<?> |
submit(java.lang.Runnable task)
Submit a Runnable task for execution, receiving a Future representing that task.
|
<T> ListenableFuture<T> |
submitListenable(java.util.concurrent.Callable<T> task)
Submit a
Callable task for execution, receiving a ListenableFuture
representing that task. |
ListenableFuture<?> |
submitListenable(java.lang.Runnable task)
Submit a
Runnable task for execution, receiving a ListenableFuture
representing that task. |
execute
public ManagedTaskExecutorAdapter(java.util.concurrent.Executor concurrentExecutor)
public void execute(java.lang.Runnable task)
TaskExecutorAdapter
execute
in interface java.util.concurrent.Executor
execute
in interface TaskExecutor
execute
in class TaskExecutorAdapter
task
- the Runnable
to execute (never null
)Executor.execute(Runnable)
public java.util.concurrent.Future<?> submit(java.lang.Runnable task)
AsyncTaskExecutor
null
result upon completion.submit
in interface AsyncTaskExecutor
submit
in class TaskExecutorAdapter
task
- the Runnable
to execute (never null
)public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)
AsyncTaskExecutor
submit
in interface AsyncTaskExecutor
submit
in class TaskExecutorAdapter
task
- the Callable
to execute (never null
)public ListenableFuture<?> submitListenable(java.lang.Runnable task)
AsyncListenableTaskExecutor
Runnable
task for execution, receiving a ListenableFuture
representing that task. The Future will return a null
result upon completion.submitListenable
in interface AsyncListenableTaskExecutor
submitListenable
in class TaskExecutorAdapter
task
- the Runnable
to execute (never null
)ListenableFuture
representing pending completion of the taskpublic <T> ListenableFuture<T> submitListenable(java.util.concurrent.Callable<T> task)
AsyncListenableTaskExecutor
Callable
task for execution, receiving a ListenableFuture
representing that task. The Future will return the Callable's result upon
completion.submitListenable
in interface AsyncListenableTaskExecutor
submitListenable
in class TaskExecutorAdapter
task
- the Callable
to execute (never null
)ListenableFuture
representing pending completion of the task