public class DefaultTaskCoordinator extends Object implements org.springframework.beans.factory.InitializingBean
Constructor and Description |
---|
DefaultTaskCoordinator(String name)
Constructor for DefaultTaskCoordinator.
|
DefaultTaskCoordinator(String name,
Executor defaultExecutor)
Constructor for DefaultTaskCoordinator.
|
Modifier and Type | Method and Description |
---|---|
void |
addDependency(Task prereq,
Task dependent)
addDependency
|
void |
addExecutor(String executorName,
Executor executor)
addExecutor
|
void |
afterPropertiesSet()
afterPropertiesSet
|
TaskBuilder<BatchTask> |
createBatch()
createBatch
|
TaskBuilder<BatchTask> |
createBatch(ContainerTask<?> parent)
createBatch
|
BatchTask |
createBatch(ContainerTask<?> parent,
Runnable... tasks)
createBatch
|
BatchTask |
createBatch(Runnable... tasks)
createBatch
|
TaskBuilder<SequenceTask> |
createSequence()
createSequence
|
TaskBuilder<SequenceTask> |
createSequence(ContainerTask<?> parent)
createSequence
|
SequenceTask |
createSequence(ContainerTask<?> parent,
Runnable... tasks)
createSequence
|
SequenceTask |
createSquence(Runnable... tasks)
createSquence
|
<T> AsyncTask<T> |
createTask(ContainerTask<?> parent,
Async<T> async,
Callback<T> cb)
createTask
|
SyncTask |
createTask(ContainerTask<?> parent,
Runnable r)
createTask
|
SyncTask |
createTask(ContainerTask<?> parent,
Runnable r,
String schedulingHint)
createTask
|
void |
schedule(Task task)
schedule
|
void |
setDefaultExecutor(String executorName)
setDefaultExecutor
|
void |
setExecutors(Map<String,Executor> executors)
setExecutors
|
void |
setLoopDelay(long millis)
setLoopDelay
|
public DefaultTaskCoordinator(String name)
Constructor for DefaultTaskCoordinator.
name
- a String
object.public void setDefaultExecutor(String executorName)
setDefaultExecutor
executorName
- a String
object.public void afterPropertiesSet()
afterPropertiesSet
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
public SyncTask createTask(ContainerTask<?> parent, Runnable r)
createTask
parent
- a ContainerTask
object.r
- a Runnable
object.SyncTask
object.public SyncTask createTask(ContainerTask<?> parent, Runnable r, String schedulingHint)
createTask
parent
- a ContainerTask
object.r
- a Runnable
object.schedulingHint
- a String
object.SyncTask
object.public <T> AsyncTask<T> createTask(ContainerTask<?> parent, Async<T> async, Callback<T> cb)
createTask
T
- a T object.parent
- a ContainerTask
object.async
- a Async
object.cb
- a Callback
object.AsyncTask
object.public TaskBuilder<BatchTask> createBatch(ContainerTask<?> parent)
createBatch
parent
- a ContainerTask
object.TaskBuilder
object.public TaskBuilder<BatchTask> createBatch()
createBatch
TaskBuilder
object.public BatchTask createBatch(ContainerTask<?> parent, Runnable... tasks)
createBatch
parent
- a ContainerTask
object.tasks
- a Runnable
object.BatchTask
object.public TaskBuilder<SequenceTask> createSequence(ContainerTask<?> parent)
createSequence
parent
- a ContainerTask
object.TaskBuilder
object.public TaskBuilder<SequenceTask> createSequence()
createSequence
TaskBuilder
object.public SequenceTask createSequence(ContainerTask<?> parent, Runnable... tasks)
createSequence
parent
- a ContainerTask
object.tasks
- a Runnable
object.SequenceTask
object.public SequenceTask createSquence(Runnable... tasks)
createSquence
tasks
- a Runnable
object.SequenceTask
object.public void setLoopDelay(long millis)
setLoopDelay
millis
- a long.Copyright © 2016. All rights reserved.