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

字段摘要
protected  Command<AcquiredJobs> acquireJobsCmd
           
protected  AcquireJobsRunnable acquireJobsRunnable
           
protected  CommandExecutor commandExecutor
           
protected  boolean isActive
           
protected  boolean isAutoActivate
           
protected  Thread jobAcquisitionThread
           
protected  String lockOwner
           
protected  int lockTimeInMillis
           
protected  int maxJobsPerAcquisition
           
protected  String name
           
protected  RejectedJobsHandler rejectedJobsHandler
           
protected  int waitTimeInMillis
           
 
构造方法摘要
JobExecutor()
           
 
方法摘要
protected  void ensureCleanup()
           
protected  void ensureInitialization()
           
protected abstract  void executeJobs(List<String> jobIds)
           
 Command<AcquiredJobs> getAcquireJobsCmd()
           
 CommandExecutor getCommandExecutor()
           
 String getLockOwner()
           
 int getLockTimeInMillis()
           
 int getMaxJobsPerAcquisition()
           
 String getName()
           
 RejectedJobsHandler getRejectedJobsHandler()
           
 int getWaitTimeInMillis()
           
 boolean isActive()
           
 boolean isAutoActivate()
           
 void jobWasAdded()
           
 void setAcquireJobsCmd(Command<AcquiredJobs> acquireJobsCmd)
           
 void setAutoActivate(boolean isAutoActivate)
           
 void setCommandExecutor(CommandExecutor commandExecutor)
           
 void setLockOwner(String lockOwner)
           
 void setLockTimeInMillis(int lockTimeInMillis)
           
 void setMaxJobsPerAcquisition(int maxJobsPerAcquisition)
           
 void setRejectedJobsHandler(RejectedJobsHandler rejectedJobsHandler)
           
 void setWaitTimeInMillis(int waitTimeInMillis)
           
 void shutdown()
           
 void start()
           
protected abstract  void startExecutingJobs()
           
protected  void startJobAcquisitionThread()
           
protected abstract  void stopExecutingJobs()
           
protected  void stopJobAcquisitionThread()
           
 
从类 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.