public interface TaskCoordinator
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_EXECUTOR
Constant
DEFAULT_EXECUTOR="default" |
static final String DEFAULT_EXECUTOR
DEFAULT_EXECUTOR="default"
SyncTask createTask(ContainerTask<?> parent, Runnable r)
createTask
parent
- a ContainerTask
object.r
- a Runnable
object.SyncTask
object.SyncTask createTask(ContainerTask<?> parent, Runnable r, String schedulingHint)
createTask
parent
- a ContainerTask
object.r
- a Runnable
object.schedulingHint
- a String
object.SyncTask
object.<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.TaskBuilder<BatchTask> createBatch(ContainerTask<?> parent)
createBatch
parent
- a ContainerTask
object.TaskBuilder
object.TaskBuilder<BatchTask> createBatch()
createBatch
TaskBuilder
object.BatchTask createBatch(ContainerTask<?> parent, Runnable... tasks)
createBatch
parent
- a ContainerTask
object.tasks
- a Runnable
object.BatchTask
object.TaskBuilder<SequenceTask> createSequence(ContainerTask<?> parent)
createSequence
parent
- a ContainerTask
object.TaskBuilder
object.TaskBuilder<SequenceTask> createSequence()
createSequence
TaskBuilder
object.SequenceTask createSequence(ContainerTask<?> parent, Runnable... tasks)
createSequence
parent
- a ContainerTask
object.tasks
- a Runnable
object.SequenceTask
object.void setLoopDelay(long millis)
setLoopDelay
millis
- a long.void schedule(AbstractTask task)
schedule
task
- a AbstractTask
object.void addDependency(AbstractTask prereq, AbstractTask dependent)
addDependency
prereq
- a AbstractTask
object.dependent
- a AbstractTask
object.void markTaskAsCompleted(AbstractTask task)
void submitToExecutor(String executorPreference, Runnable workToBeDone, AbstractTask owningTask)
void addOrUpdateExecutor(String executorName, Executor executor)
addOrUpdateExecutor
Copyright © 2017. All rights reserved.