public class SimulationDefaultJobExecutor extends DefaultJobExecutor
corePoolSize, keepAliveTime, maxPoolSize, queueSize, threadPoolExecutor, threadPoolQueueacquireJobsCmd, acquireJobsRunnable, clockReader, commandExecutor, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxJobsPerAcquisition, name, rejectedJobsHandler, waitTimeInMillis| Constructor and Description |
|---|
SimulationDefaultJobExecutor() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ensureInitialization()
use SimulationAcquireJobsRunnable instead of AcquireJobsRunnable.
|
void |
executeJobs(List<String> jobIds)
do not execute new thread - simulation time can move too forward.
|
AcquireJobsRunnable |
getAcquireJobsRunnable() |
protected void |
startJobAcquisitionThread() |
protected void |
stopJobAcquisitionThread() |
getCorePoolSize, getKeepAliveTime, getMaxPoolSize, getQueueSize, getThreadPoolExecutor, getThreadPoolQueue, setCorePoolSize, setKeepAliveTime, setMaxPoolSize, setQueueSize, setThreadPoolExecutor, setThreadPoolQueue, startExecutingJobs, stopExecutingJobsensureCleanup, getAcquireJobsCmd, getCommandExecutor, getCurrentTime, getLockOwner, getLockTimeInMillis, getMaxJobsPerAcquisition, getName, getRejectedJobsHandler, getWaitTimeInMillis, isActive, isAutoActivate, jobDone, jobDone, jobWasAdded, setAcquireJobsCmd, setAcquireJobsRunnable, setAutoActivate, setClockReader, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxJobsPerAcquisition, setRejectedJobsHandler, setWaitTimeInMillis, shutdown, startprotected void ensureInitialization()
ensureInitialization in class JobExecutorpublic void executeJobs(List<String> jobIds)
executeJobs in class DefaultJobExecutorpublic AcquireJobsRunnable getAcquireJobsRunnable()
getAcquireJobsRunnable in class JobExecutorprotected void startJobAcquisitionThread()
startJobAcquisitionThread in class JobExecutorprotected void stopJobAcquisitionThread()
stopJobAcquisitionThread in class JobExecutorCopyright © 2016 Alfresco. All rights reserved.