|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.springframework.scheduling.concurrent.ConcurrentTaskExecutor
public class ConcurrentTaskExecutor
Adapter that takes a JDK 1.5 java.util.concurrent.Executor and
exposes a Spring TaskExecutor for it.
NOTE: This class implements Spring's
TaskExecutor interface as well as the JDK 1.5
Executor interface, with the former being the primary
interface, the other just serving as secondary convenience. For this reason, the
exception handling follows the TaskExecutor contract rather than the Executor contract,
in particular regarding the TaskRejectedException.
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,
ThreadPoolExecutor,
Executors,
ThreadPoolTaskExecutor| Constructor Summary | |
|---|---|
ConcurrentTaskExecutor()
Create a new ConcurrentTaskExecutor, using a single thread executor as default. |
|
ConcurrentTaskExecutor(Executor concurrentExecutor)
Create a new ConcurrentTaskExecutor, using the given JDK 1.5 concurrent executor. |
|
| Method Summary | |
|---|---|
void |
execute(Runnable task)
Delegates to the specified JDK 1.5 concurrent executor. |
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(Executor concurrentExecutor)
Specify the JDK 1.5 concurrent executor to delegate to. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public ConcurrentTaskExecutor()
Executors.newSingleThreadExecutor()public ConcurrentTaskExecutor(Executor concurrentExecutor)
concurrentExecutor - the JDK 1.5 concurrent executor to delegate to| Method Detail |
|---|
public void setConcurrentExecutor(Executor concurrentExecutor)
public Executor getConcurrentExecutor()
public void execute(Runnable task)
execute in interface Executorexecute in interface TaskExecutortask - the Runnable to execute (never null)Executor.execute(Runnable)public boolean prefersShortLivedTasks()
prefersShortLivedTasks in interface SchedulingTaskExecutortrue if this TaskExecutor prefers
short-lived tasks
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||