org.activiti.engine.impl.jobexecutor
类 JobExecutor
java.lang.Object
org.activiti.engine.impl.jobexecutor.JobExecutor
- 直接已知子类:
- DefaultJobExecutor
public abstract class JobExecutor
- extends Object
Interface to the work management component of activiti.
This component is responsible for performing all background work
(Jobs
) scheduled by activiti.
You should generally only have one of these per Activiti instance (process
engine) in a JVM.
In clustered situations, you can have multiple of these running against the
same queue + pending job list.
- 作者:
- Daniel Meyer
从类 java.lang.Object 继承的方法 |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
name
protected String name
commandExecutor
protected CommandExecutor commandExecutor
acquireJobsCmd
protected Command<AcquiredJobs> acquireJobsCmd
acquireJobsRunnable
protected AcquireJobsRunnable acquireJobsRunnable
rejectedJobsHandler
protected RejectedJobsHandler rejectedJobsHandler
jobAcquisitionThread
protected Thread jobAcquisitionThread
isAutoActivate
protected boolean isAutoActivate
isActive
protected boolean isActive
maxJobsPerAcquisition
protected int maxJobsPerAcquisition
waitTimeInMillis
protected int waitTimeInMillis
lockOwner
protected String lockOwner
lockTimeInMillis
protected int lockTimeInMillis
JobExecutor
public JobExecutor()
start
public void start()
shutdown
public void shutdown()
ensureInitialization
protected void ensureInitialization()
ensureCleanup
protected void ensureCleanup()
jobWasAdded
public void jobWasAdded()
startExecutingJobs
protected abstract void startExecutingJobs()
stopExecutingJobs
protected abstract void stopExecutingJobs()
executeJobs
protected abstract void executeJobs(List<String> jobIds)
getCommandExecutor
public CommandExecutor getCommandExecutor()
getWaitTimeInMillis
public int getWaitTimeInMillis()
setWaitTimeInMillis
public void setWaitTimeInMillis(int waitTimeInMillis)
getLockTimeInMillis
public int getLockTimeInMillis()
setLockTimeInMillis
public void setLockTimeInMillis(int lockTimeInMillis)
getLockOwner
public String getLockOwner()
setLockOwner
public void setLockOwner(String lockOwner)
isAutoActivate
public boolean isAutoActivate()
setCommandExecutor
public void setCommandExecutor(CommandExecutor commandExecutor)
setAutoActivate
public void setAutoActivate(boolean isAutoActivate)
getMaxJobsPerAcquisition
public int getMaxJobsPerAcquisition()
setMaxJobsPerAcquisition
public void setMaxJobsPerAcquisition(int maxJobsPerAcquisition)
getName
public String getName()
getAcquireJobsCmd
public Command<AcquiredJobs> getAcquireJobsCmd()
setAcquireJobsCmd
public void setAcquireJobsCmd(Command<AcquiredJobs> acquireJobsCmd)
isActive
public boolean isActive()
getRejectedJobsHandler
public RejectedJobsHandler getRejectedJobsHandler()
setRejectedJobsHandler
public void setRejectedJobsHandler(RejectedJobsHandler rejectedJobsHandler)
startJobAcquisitionThread
protected void startJobAcquisitionThread()
stopJobAcquisitionThread
protected void stopJobAcquisitionThread()
Copyright © 2013 Alfresco. All rights reserved.