io.stallion.asyncTasks

Class AsyncDbCoordinator

java.lang.Object

java.lang.Thread

io.stallion.asyncTasks.AsyncCoordinator

io.stallion.asyncTasks.AsyncFileCoordinator

io.stallion.asyncTasks.AsyncDbCoordinator

All Implemented Interfaces:

Runnable

public class AsyncDbCoordinator
extends AsyncFileCoordinator

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AsyncDbCoordinator()

Method Summary

Modifier and Type	Method and Description
AsyncTask	findAndLockNextTask(Long now) Find the next task that is unlocked and ready for execution, lock it, and return it.
boolean	hasTaskWithId(Long taskId) Check to see if the task with the given id exists in the queue
boolean	markCompleted(AsyncTask task) Mark the task as completed.
boolean	markFailed(AsyncTask task, Throwable throwable) Mark the task as failed.
void	saveNewTask(AsyncTask task) Save a new task to the data store
void	updateTask(AsyncTask task, boolean executeAtChanged) Update a task with new information.

Methods inherited from class io.stallion.asyncTasks.AsyncFileCoordinator

enqueue, enqueue, enqueue, getPendingTaskCount, getTaskPersister, getTaskQueue, hasPendingTaskWithCustomKey, hasSeenTask, hasTaskWithCustomKey, lockTaskForExecution, onLoadTaskOnBoot

Methods inherited from class io.stallion.asyncTasks.AsyncCoordinator

executeNext, executeNext, getExtraClassLoaders, gracefulShutdown, init, initAndStart, initEphemeralSynchronousForTests, initForTests, instance, isSynchronousMode, registerClassLoader, registerHandler, registerHandler, run, runTaskForId, shutDownForTests, startup

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncDbCoordinator

public AsyncDbCoordinator()

Method Detail

updateTask

public void updateTask(AsyncTask task,
                       boolean executeAtChanged)

Description copied from class: AsyncCoordinator

Update a task with new information.

Overrides:

updateTask in class AsyncFileCoordinator

saveNewTask

public void saveNewTask(AsyncTask task)

Description copied from class: AsyncCoordinator

Save a new task to the data store

Overrides:

saveNewTask in class AsyncFileCoordinator

findAndLockNextTask

public AsyncTask findAndLockNextTask(Long now)

Description copied from class: AsyncCoordinator

Find the next task that is unlocked and ready for execution, lock it, and return it.

Overrides:

findAndLockNextTask in class AsyncFileCoordinator

Returns:

markCompleted

public boolean markCompleted(AsyncTask task)

Description copied from class: AsyncCoordinator

Mark the task as completed.

Overrides:

markCompleted in class AsyncFileCoordinator

Returns:

markFailed

public boolean markFailed(AsyncTask task,
                          Throwable throwable)

Description copied from class: AsyncCoordinator

Mark the task as failed.

Overrides:

markFailed in class AsyncFileCoordinator

Returns:

hasTaskWithId

public boolean hasTaskWithId(Long taskId)

Description copied from class: AsyncCoordinator

Check to see if the task with the given id exists in the queue

Overrides:

hasTaskWithId in class AsyncFileCoordinator

Returns: