public class ThreadPoolJobExecutor extends JobExecutor
Modifier and Type | Field and Description |
---|---|
protected ThreadPoolExecutor |
threadPoolExecutor |
acquireJobsCmdFactory, acquireJobsRunnable, backoffDecreaseThreshold, backoffTimeInMillis, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxBackoff, maxJobsPerAcquisition, maxWait, name, processEngines, rejectedJobsHandler, waitIncreaseFactor, waitTimeInMillis
Constructor and Description |
---|
ThreadPoolJobExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
executeJobs(List<String> jobIds,
ProcessEngineImpl processEngine) |
ThreadPoolExecutor |
getThreadPoolExecutor() |
void |
setThreadPoolExecutor(ThreadPoolExecutor threadPoolExecutor) |
protected void |
startExecutingJobs() |
protected void |
stopExecutingJobs() |
engineIterator, ensureCleanup, ensureInitialization, executeJobs, getAcquireJobsCmd, getAcquireJobsCmdFactory, getAcquireJobsRunnable, getBackoffDecreaseThreshold, getBackoffTimeInMillis, getCommandExecutor, getExecuteJobsRunnable, getLockOwner, getLockTimeInMillis, getMaxBackoff, getMaxJobsPerAcquisition, getMaxWait, getName, getProcessEngines, getRejectedJobsHandler, getWaitIncreaseFactor, getWaitTimeInMillis, hasRegisteredEngine, isActive, isAutoActivate, jobWasAdded, logAcquiredJobs, logAcquisitionAttempt, logAcquisitionFailureJobs, logRejectedExecution, registerProcessEngine, setAcquireJobsCmdFactory, setAutoActivate, setBackoffDecreaseThreshold, setBackoffTimeInMillis, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxBackoff, setMaxJobsPerAcquisition, setMaxWait, setProcessEngines, setRejectedJobsHandler, setWaitIncreaseFactor, setWaitTimeInMillis, shutdown, start, startJobAcquisitionThread, stopJobAcquisitionThread, unregisterProcessEngine
protected ThreadPoolExecutor threadPoolExecutor
protected void startExecutingJobs()
startExecutingJobs
in class JobExecutor
protected void stopExecutingJobs()
stopExecutingJobs
in class JobExecutor
public void executeJobs(List<String> jobIds, ProcessEngineImpl processEngine)
executeJobs
in class JobExecutor
public ThreadPoolExecutor getThreadPoolExecutor()
public void setThreadPoolExecutor(ThreadPoolExecutor threadPoolExecutor)
Copyright © 2020. All rights reserved.