ai.grakn.engine.backgroundtasks

Class InMemoryTaskManager

java.lang.Object

ai.grakn.engine.backgroundtasks.AbstractTaskManager

ai.grakn.engine.backgroundtasks.InMemoryTaskManager

All Implemented Interfaces:

TaskManager

public class InMemoryTaskManager
extends AbstractTaskManager

Method Summary

Modifier and Type	Method and Description
protected void	executeRecurring(UUID uuid, BackgroundTask task, long delay, long interval)
protected void	executeSingle(UUID uuid, BackgroundTask task, long delay)
Set<UUID>	getAllTasks() Returns a Set of all tasks in the system - this includes Completed, Running, Dead, etc.
static InMemoryTaskManager	getInstance()
protected ScheduledFuture<BackgroundTask>	getTaskExecutionStatus(UUID uuid)
Set<UUID>	getTasks(TaskStatus taskStatus) Return a Set of all tasks with a matching @TaskStatus.
TaskState	getTaskState(UUID uuid) Return the full TaskState object for a given task, containing full task metadata including the status change messages and reqesterNames as provided in the stopTask/pauseTask/resumeTask and restartTask methods.
protected BackgroundTask	instantiateTask(String className)
protected UUID	saveNewState(TaskState state)
TaskManager	stopTask(UUID uuid)

Methods inherited from class ai.grakn.engine.backgroundtasks.AbstractTaskManager

scheduleRecurringTask, scheduleTask, stopTask

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static InMemoryTaskManager getInstance()

stopTask

public TaskManager stopTask(UUID uuid)

getTaskState

public TaskState getTaskState(UUID uuid)

Description copied from interface: TaskManager

Return the full TaskState object for a given task, containing full task metadata including the status change messages and reqesterNames as provided in the stopTask/pauseTask/resumeTask and restartTask methods.

Parameters:

uuid - UUID of task to stop.

Returns:

TaskState object. See @TaskState.

getAllTasks

public Set<UUID> getAllTasks()

Description copied from interface: TaskManager

Returns a Set of all tasks in the system - this includes Completed, Running, Dead, etc.

Returns:

Set<> of task UUID's

getTasks

public Set<UUID> getTasks(TaskStatus taskStatus)

Description copied from interface: TaskManager

Return a Set of all tasks with a matching @TaskStatus. Example: // Return all tasks which failed to complete execution. Set failedTasks = myTaskManager.getTasks(TaskStatus.DEAD);

Parameters:

taskStatus - See TaskStatus enum.

Returns:

Set<> of task UUID's matching the given @taskStatus.

saveNewState

protected UUID saveNewState(TaskState state)

Specified by:

saveNewState in class AbstractTaskManager

instantiateTask

protected BackgroundTask instantiateTask(String className)
                                  throws ClassNotFoundException,
                                         InstantiationException,
                                         IllegalAccessException

Specified by:

instantiateTask in class AbstractTaskManager

Throws:

ClassNotFoundException

InstantiationException

IllegalAccessException

executeSingle

protected void executeSingle(UUID uuid,
                             BackgroundTask task,
                             long delay)

Specified by:

executeSingle in class AbstractTaskManager

executeRecurring

protected void executeRecurring(UUID uuid,
                                BackgroundTask task,
                                long delay,
                                long interval)

Specified by:

executeRecurring in class AbstractTaskManager

getTaskExecutionStatus

protected ScheduledFuture<BackgroundTask> getTaskExecutionStatus(UUID uuid)

Specified by:

getTaskExecutionStatus in class AbstractTaskManager