public class TaskManager<C extends ApplicationContext> extends AbstractApplicationObject<C> implements CloseableComponent
AsyncTask
s in order to be able to
access them by TaskId
and cancel them at any time. It also maintains a ActiveTasksListModel
which
keeps references to the RunStateFlag
of the currently running tasks. This ListModel is linked to the taskMap
for canceling tasks.Constructor and Description |
---|
TaskManager(C ctx) |
Modifier and Type | Method and Description |
---|---|
int |
cancelAll() |
boolean |
cancelTask(TaskId taskId)
Cancels the running task by
TaskId . |
protected void |
checkForActivity(java.util.Map<java.lang.String,java.lang.Integer> activityMap,
ActivityListModel listModel)
Adds the count of active async components to the activityMap
|
void |
close() |
void |
deregisterTask(AsyncTask task) |
void |
fillCurrentActivity(java.util.Map<java.lang.String,java.lang.Integer> activityMap)
Stores the current item-count in the given activityMap.
|
java.util.List<TaskId> |
findAllCancellableTaskIds()
Returns a List of all
TaskId s that are registered for cancellation. |
java.util.List<TaskId> |
findAllNonCancellableTaskIds()
Returns a List of all
TaskId s that are registered but uncancellable. |
AsyncTask |
findTask(TaskId taskId) |
AsyncTask |
findTaskByName(java.lang.String taskName) |
ActiveOsProcessesListModel |
getActiveOsProcessesListModel() |
ActiveTasksListModel |
getActiveTasksListModel() |
ActiveWorkflowsListModel |
getActiveWorkflowsListModel() |
java.util.concurrent.ThreadPoolExecutor |
getAsyncExecutor() |
int |
getTaskCount() |
void |
registerTask(AsyncTask task) |
void |
registerTaskStateChange(RunStateFlag stateFlag) |
getApplicationContext, getLogChannel, isLogDebug, isLogVerbose, logDebug, logDump, logError, logError, logFatal, logInfo, logVerbose, logWarning, setLogChannel
configureDumpHeadlineLength, configureDumpMaxElementsPrinted, copyDumpStringValues, copyToStringValues, createDumpHeader, toDumpString, toDumpString, toString, toString
public TaskManager(C ctx)
public java.util.concurrent.ThreadPoolExecutor getAsyncExecutor()
public ActiveTasksListModel getActiveTasksListModel()
public ActiveWorkflowsListModel getActiveWorkflowsListModel()
public ActiveOsProcessesListModel getActiveOsProcessesListModel()
public int cancelAll()
public void close()
close
in interface java.lang.AutoCloseable
public boolean cancelTask(TaskId taskId)
TaskId
.public AsyncTask findTaskByName(java.lang.String taskName)
public void registerTask(AsyncTask task)
public void deregisterTask(AsyncTask task)
public int getTaskCount()
public final java.util.List<TaskId> findAllCancellableTaskIds()
TaskId
s that are registered for cancellation.public java.util.List<TaskId> findAllNonCancellableTaskIds()
TaskId
s that are registered but uncancellable.public void fillCurrentActivity(java.util.Map<java.lang.String,java.lang.Integer> activityMap)
protected final void checkForActivity(java.util.Map<java.lang.String,java.lang.Integer> activityMap, ActivityListModel listModel)
public void registerTaskStateChange(RunStateFlag stateFlag)
Copyright © 2014 EsprIT-Systems. All Rights Reserved.