Package org.opennms.core.tasks
Interface TaskCoordinator
-
- All Known Implementing Classes:
DefaultTaskCoordinator
public interface TaskCoordinator
TaskCoordinator- Version:
- $Id: $
- Author:
- brozow
-
-
Field Summary
Fields Modifier and Type Field Description static String
DEFAULT_EXECUTOR
ConstantDEFAULT_EXECUTOR="default"
-
Method Summary
-
-
-
Field Detail
-
DEFAULT_EXECUTOR
static final String DEFAULT_EXECUTOR
ConstantDEFAULT_EXECUTOR="default"
- See Also:
- Constant Field Values
-
-
Method Detail
-
createTask
SyncTask createTask(ContainerTask<?> parent, Runnable r)
createTask
- Parameters:
parent
- aContainerTask
object.r
- aRunnable
object.- Returns:
- a
SyncTask
object.
-
createTask
SyncTask createTask(ContainerTask<?> parent, Runnable r, String schedulingHint)
createTask
- Parameters:
parent
- aContainerTask
object.r
- aRunnable
object.schedulingHint
- aString
object.- Returns:
- a
SyncTask
object.
-
createTask
<T> AsyncTask<T> createTask(ContainerTask<?> parent, Async<T> async, Callback<T> cb)
createTask
- Type Parameters:
T
- a T object.- Parameters:
parent
- aContainerTask
object.async
- aAsync
object.cb
- aCallback
object.- Returns:
- a
AsyncTask
object.
-
createBatch
TaskBuilder<BatchTask> createBatch(ContainerTask<?> parent)
createBatch
- Parameters:
parent
- aContainerTask
object.- Returns:
- a
TaskBuilder
object.
-
createBatch
TaskBuilder<BatchTask> createBatch()
createBatch
- Returns:
- a
TaskBuilder
object.
-
createBatch
BatchTask createBatch(ContainerTask<?> parent, Runnable... tasks)
createBatch
- Parameters:
parent
- aContainerTask
object.tasks
- aRunnable
object.- Returns:
- a
BatchTask
object.
-
createSequence
TaskBuilder<SequenceTask> createSequence(ContainerTask<?> parent)
createSequence
- Parameters:
parent
- aContainerTask
object.- Returns:
- a
TaskBuilder
object.
-
createSequence
TaskBuilder<SequenceTask> createSequence()
createSequence
- Returns:
- a
TaskBuilder
object.
-
createSequence
SequenceTask createSequence(ContainerTask<?> parent, Runnable... tasks)
createSequence
- Parameters:
parent
- aContainerTask
object.tasks
- aRunnable
object.- Returns:
- a
SequenceTask
object.
-
setLoopDelay
void setLoopDelay(long millis)
setLoopDelay
- Parameters:
millis
- a long.
-
schedule
void schedule(AbstractTask task)
schedule
- Parameters:
task
- aAbstractTask
object.
-
addDependency
void addDependency(AbstractTask prereq, AbstractTask dependent)
addDependency
- Parameters:
prereq
- aAbstractTask
object.dependent
- aAbstractTask
object.
-
markTaskAsCompleted
void markTaskAsCompleted(AbstractTask task)
-
submitToExecutor
void submitToExecutor(String executorPreference, Runnable workToBeDone, AbstractTask owningTask)
-
addOrUpdateExecutor
void addOrUpdateExecutor(String executorName, Executor executor)
addOrUpdateExecutor
-
-