public class ConcurrentTaskExecutor extends java.lang.Object implements SchedulingTaskExecutor
java.util.concurrent.Executor
and
exposes a Spring TaskExecutor
for it.
Also detects an extended java.util.concurrent.ExecutorService
, adapting
the AsyncTaskExecutor
interface accordingly.
Note that there is a pre-built ThreadPoolTaskExecutor
that allows for
defining a JDK 1.5 ThreadPoolExecutor
in bean style,
exposing it as a Spring TaskExecutor
directly.
This is a convenient alternative to a raw ThreadPoolExecutor definition with
a separate definition of the present adapter class.
Executor
,
ExecutorService
,
ThreadPoolExecutor
,
Executors
,
ThreadPoolTaskExecutor
Modifier and Type | Field and Description |
---|---|
private TaskExecutorAdapter |
adaptedExecutor |
private java.util.concurrent.Executor |
concurrentExecutor |
TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE
Constructor and Description |
---|
ConcurrentTaskExecutor()
Create a new ConcurrentTaskExecutor,
using a single thread executor as default.
|
ConcurrentTaskExecutor(java.util.concurrent.Executor concurrentExecutor)
Create a new ConcurrentTaskExecutor,
using the given JDK 1.5 concurrent executor.
|
Modifier and Type | Method and Description |
---|---|
void |
execute(java.lang.Runnable task)
Execute the given
task . |
void |
execute(java.lang.Runnable task,
long startTimeout)
Execute the given
task . |
java.util.concurrent.Executor |
getConcurrentExecutor()
Return the JDK 1.5 concurrent executor that this adapter delegates to.
|
boolean |
prefersShortLivedTasks()
This task executor prefers short-lived work units.
|
void |
setConcurrentExecutor(java.util.concurrent.Executor concurrentExecutor)
Specify the JDK 1.5 concurrent executor to delegate to.
|
<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.
|
private java.util.concurrent.Executor concurrentExecutor
private TaskExecutorAdapter adaptedExecutor
public ConcurrentTaskExecutor()
Executors.newSingleThreadExecutor()
public ConcurrentTaskExecutor(java.util.concurrent.Executor concurrentExecutor)
concurrentExecutor
- the JDK 1.5 concurrent executor to delegate topublic final void setConcurrentExecutor(java.util.concurrent.Executor concurrentExecutor)
public final java.util.concurrent.Executor getConcurrentExecutor()
public void execute(java.lang.Runnable task)
TaskExecutor
task
.
The call might return immediately if the implementation uses an asynchronous execution strategy, or might block in the case of synchronous execution.
execute
in interface java.util.concurrent.Executor
execute
in interface TaskExecutor
task
- the Runnable
to execute (never null
)public void execute(java.lang.Runnable task, long startTimeout)
AsyncTaskExecutor
task
.execute
in interface AsyncTaskExecutor
task
- the Runnable
to execute (never null
)startTimeout
- the time duration (milliseconds) within which the task is
supposed to start. This is intended as a hint to the executor, allowing for
preferred handling of immediate tasks. Typical values are AsyncTaskExecutor.TIMEOUT_IMMEDIATE
or AsyncTaskExecutor.TIMEOUT_INDEFINITE
(the default as used by TaskExecutor.execute(Runnable)
).public java.util.concurrent.Future<?> submit(java.lang.Runnable task)
AsyncTaskExecutor
null
result upon completion.submit
in interface AsyncTaskExecutor
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
task
- the Callable
to execute (never null
)public boolean prefersShortLivedTasks()
prefersShortLivedTasks
in interface SchedulingTaskExecutor
true
if this TaskExecutor
prefers
short-lived tasks