org.springframework.scheduling.concurrent

Class ConcurrentTaskExecutor.ManagedTaskExecutorAdapter

java.lang.Object

org.springframework.core.task.support.TaskExecutorAdapter

org.springframework.scheduling.concurrent.ConcurrentTaskExecutor.ManagedTaskExecutorAdapter

All Implemented Interfaces:

java.util.concurrent.Executor, AsyncListenableTaskExecutor, AsyncTaskExecutor, TaskExecutor

Enclosing class:

ConcurrentTaskExecutor

private static class ConcurrentTaskExecutor.ManagedTaskExecutorAdapter
extends TaskExecutorAdapter

TaskExecutorAdapter subclass that wraps all provided Runnables and Callables with a JSR-236 ManagedTask, exposing a long-running hint based on SchedulingAwareRunnable and an identity name based on the task's toString() representation.

Field Summary

Fields inherited from interface org.springframework.core.task.AsyncTaskExecutor

TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE

Constructor Summary

Constructors

Constructor and Description
ManagedTaskExecutorAdapter(java.util.concurrent.Executor concurrentExecutor)

Method Summary

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.

Methods inherited from class org.springframework.core.task.support.TaskExecutorAdapter

execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ManagedTaskExecutorAdapter

public ManagedTaskExecutorAdapter(java.util.concurrent.Executor concurrentExecutor)

Method Detail

execute

public void execute(java.lang.Runnable task)

Description copied from class: TaskExecutorAdapter

Delegates to the specified JDK concurrent executor.

Specified by:

execute in interface java.util.concurrent.Executor

Specified by:

execute in interface TaskExecutor

Overrides:

execute in class TaskExecutorAdapter

Parameters:

task - the Runnable to execute (never null)

See Also:

Executor.execute(Runnable)

submit

public java.util.concurrent.Future<?> submit(java.lang.Runnable task)

Description copied from interface: AsyncTaskExecutor

Submit a Runnable task for execution, receiving a Future representing that task. The Future will return a null result upon completion.

Specified by:

submit in interface AsyncTaskExecutor

Overrides:

submit in class TaskExecutorAdapter

Parameters:

task - the Runnable to execute (never null)

Returns:

a Future representing pending completion of the task

submit

public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)

Description copied from interface: AsyncTaskExecutor

Submit a Callable task for execution, receiving a Future representing that task. The Future will return the Callable's result upon completion.

Specified by:

submit in interface AsyncTaskExecutor

Overrides:

submit in class TaskExecutorAdapter

Parameters:

task - the Callable to execute (never null)

Returns:

a Future representing pending completion of the task

submitListenable

public ListenableFuture<?> submitListenable(java.lang.Runnable task)

Description copied from interface: AsyncListenableTaskExecutor

Submit a Runnable task for execution, receiving a ListenableFuture representing that task. The Future will return a null result upon completion.

Specified by:

submitListenable in interface AsyncListenableTaskExecutor

Overrides:

submitListenable in class TaskExecutorAdapter

Parameters:

task - the Runnable to execute (never null)

Returns:

a ListenableFuture representing pending completion of the task

submitListenable

public <T> ListenableFuture<T> submitListenable(java.util.concurrent.Callable<T> task)

Description copied from interface: AsyncListenableTaskExecutor

Submit a Callable task for execution, receiving a ListenableFuture representing that task. The Future will return the Callable's result upon completion.

Specified by:

submitListenable in interface AsyncListenableTaskExecutor

Overrides:

submitListenable in class TaskExecutorAdapter

Parameters:

task - the Callable to execute (never null)

Returns:

a ListenableFuture representing pending completion of the task