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	Constant DEFAULT_EXECUTOR="default"

Method Summary

Modifier and Type	Method	Description
void	addDependency(AbstractTask prereq, AbstractTask dependent)	addDependency
void	addOrUpdateExecutor(String executorName, Executor executor)	addOrUpdateExecutor
TaskBuilder<BatchTask>	createBatch()	createBatch
BatchTask	createBatch(Runnable... tasks)	createBatch
TaskBuilder<BatchTask>	createBatch(ContainerTask<?> parent)	createBatch
BatchTask	createBatch(ContainerTask<?> parent, Runnable... tasks)	createBatch
TaskBuilder<SequenceTask>	createSequence()	createSequence
TaskBuilder<SequenceTask>	createSequence(ContainerTask<?> parent)	createSequence
SequenceTask	createSequence(ContainerTask<?> parent, Runnable... tasks)	createSequence
SyncTask	createTask(ContainerTask<?> parent, Runnable r)	createTask
SyncTask	createTask(ContainerTask<?> parent, Runnable r, String schedulingHint)	createTask
<T> AsyncTask<T>	createTask(ContainerTask<?> parent, Async<T> async, Callback<T> cb)	createTask
void	markTaskAsCompleted(AbstractTask task)
void	schedule(AbstractTask task)	schedule
void	setExecutors(Map<String,Executor> executors)	setExecutors
void	setLoopDelay(long millis)	setLoopDelay
void	submitToExecutor(String executorPreference, Runnable workToBeDone, AbstractTask owningTask)

Field Detail

DEFAULT_EXECUTOR

static final String DEFAULT_EXECUTOR

Constant DEFAULT_EXECUTOR="default"

See Also:

Constant Field Values

Method Detail

createTask

SyncTask createTask(ContainerTask<?> parent,
                    Runnable r)

createTask

Parameters:

parent - a ContainerTask object.

r - a Runnable object.

Returns:

a SyncTask object.

createTask

SyncTask createTask(ContainerTask<?> parent,
                    Runnable r,
                    String schedulingHint)

createTask

Parameters:

parent - a ContainerTask object.

r - a Runnable object.

schedulingHint - a String 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 - a ContainerTask object.

async - a Async object.

cb - a Callback object.

Returns:

a AsyncTask object.

createBatch

TaskBuilder<BatchTask> createBatch(ContainerTask<?> parent)

createBatch

Parameters:

parent - a ContainerTask object.

Returns:

a TaskBuilder object.

createBatch

TaskBuilder<BatchTask> createBatch()

createBatch

Returns:

a TaskBuilder object.

createBatch

BatchTask createBatch(ContainerTask<?> parent,
                      Runnable... tasks)

createBatch

Parameters:

parent - a ContainerTask object.

tasks - a Runnable object.

Returns:

a BatchTask object.

createBatch

BatchTask createBatch(Runnable... tasks)

createBatch

Parameters:

tasks - a Runnable object.

Returns:

a BatchTask object.

createSequence

TaskBuilder<SequenceTask> createSequence(ContainerTask<?> parent)

createSequence

Parameters:

parent - a ContainerTask object.

Returns:

a TaskBuilder object.

createSequence

TaskBuilder<SequenceTask> createSequence()

createSequence

Returns:

a TaskBuilder object.

createSequence

SequenceTask createSequence(ContainerTask<?> parent,
                            Runnable... tasks)

createSequence

Parameters:

parent - a ContainerTask object.

tasks - a Runnable object.

Returns:

a SequenceTask object.

setLoopDelay

void setLoopDelay(long millis)

setLoopDelay

Parameters:

millis - a long.

schedule

void schedule(AbstractTask task)

schedule

Parameters:

task - a AbstractTask object.

addDependency

void addDependency(AbstractTask prereq,
                   AbstractTask dependent)

addDependency

Parameters:

prereq - a AbstractTask object.

dependent - a AbstractTask object.

markTaskAsCompleted

void markTaskAsCompleted(AbstractTask task)

submitToExecutor

void submitToExecutor(String executorPreference,
                      Runnable workToBeDone,
                      AbstractTask owningTask)

addOrUpdateExecutor

void addOrUpdateExecutor(String executorName,
                         Executor executor)

addOrUpdateExecutor

Parameters:

executorName - a String object.

executor - a Executor object.

setExecutors

void setExecutors(Map<String,Executor> executors)

setExecutors

Parameters:

executors - a Map object.