Package org.camunda.bpm.engine.impl.jobexecutor

Class ThreadPoolJobExecutor

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.JobExecutor

org.camunda.bpm.engine.impl.jobexecutor.ThreadPoolJobExecutor

Direct Known Subclasses:

DefaultJobExecutor

public class ThreadPoolJobExecutor
extends JobExecutor

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.ThreadPoolExecutor	threadPoolExecutor

Fields inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobExecutor

acquireJobsCmdFactory, acquireJobsRunnable, backoffDecreaseThreshold, backoffTimeInMillis, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxBackoff, maxJobsPerAcquisition, maxWait, name, processEngines, rejectedJobsHandler, waitIncreaseFactor, waitTimeInMillis

Constructor Summary

Constructors

Constructor	Description
ThreadPoolJobExecutor()

Method Summary

Modifier and Type	Method	Description
void	executeJobs(java.util.List<java.lang.String> jobIds, ProcessEngineImpl processEngine)
java.util.concurrent.ThreadPoolExecutor	getThreadPoolExecutor()
void	setThreadPoolExecutor(java.util.concurrent.ThreadPoolExecutor threadPoolExecutor)
protected void	startExecutingJobs()
protected void	stopExecutingJobs()

Methods inherited from class org.camunda.bpm.engine.impl.jobexecutor.JobExecutor

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

Methods inherited from class java.lang.Object

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

Field Detail

threadPoolExecutor

protected java.util.concurrent.ThreadPoolExecutor threadPoolExecutor

Constructor Detail

ThreadPoolJobExecutor

public ThreadPoolJobExecutor()

Method Detail

startExecutingJobs

protected void startExecutingJobs()

Specified by:

startExecutingJobs in class JobExecutor

stopExecutingJobs

protected void stopExecutingJobs()

Specified by:

stopExecutingJobs in class JobExecutor

executeJobs

public void executeJobs(java.util.List<java.lang.String> jobIds,
                        ProcessEngineImpl processEngine)

Specified by:

executeJobs in class JobExecutor

getThreadPoolExecutor

public java.util.concurrent.ThreadPoolExecutor getThreadPoolExecutor()

setThreadPoolExecutor

public void setThreadPoolExecutor(java.util.concurrent.ThreadPoolExecutor threadPoolExecutor)