public class BatchTaskExecutor extends java.util.concurrent.ScheduledThreadPoolExecutor implements ServerObject<ServerContext>
AbstractBatchTask
sjava.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy
Constructor and Description |
---|
BatchTaskExecutor(ServerContext serverCtx) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancelCurrentTask(SessionId killerId) |
void |
clearAll() |
AbstractBatchTask |
getCurrentTask() |
ServerContext |
getServerContext()
Returns the server runtime environment
|
boolean |
hasCurrentTask() |
void |
setCurrentTask(AbstractBatchTask currentTask) |
decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit
afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor
public BatchTaskExecutor(ServerContext serverCtx)
public ServerContext getServerContext()
ServerObject
getServerContext
in interface ServerObject<ServerContext>
public boolean cancelCurrentTask(SessionId killerId)
public void clearAll()
public AbstractBatchTask getCurrentTask()
public boolean hasCurrentTask()
public void setCurrentTask(AbstractBatchTask currentTask)
Copyright © 2014 EsprIT-Systems. All Rights Reserved.