org.activiti.engine.impl.jobexecutor
类 DefaultJobExecutor

java.lang.Object
  继承者 org.activiti.engine.impl.jobexecutor.JobExecutor
      继承者 org.activiti.engine.impl.jobexecutor.DefaultJobExecutor

public class DefaultJobExecutor
extends JobExecutor

This is a simple implementation of the JobExecutor using self-managed threads for performing background work.

This implementation uses a ThreadPoolExecutor backed by a queue to which work is submitted.

NOTE: use this class in environments in which self-management of threads is permitted. Consider using a different thread-management strategy in J(2)EE-Environments.

作者:
Daniel Meyer

字段摘要
protected  int corePoolSize
           
protected  int queueSize
           
protected  ThreadPoolExecutor threadPoolExecutor
           
protected  BlockingQueue<Runnable> threadPoolQueue
           
 
从类 org.activiti.engine.impl.jobexecutor.JobExecutor 继承的字段
acquireJobsCmd, acquireJobsRunnable, commandExecutor, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxJobsPerAcquisition, name, rejectedJobsHandler, waitTimeInMillis
 
构造方法摘要
DefaultJobExecutor()
           
 
方法摘要
 void executeJobs(List<String> jobIds)
           
 int getCorePoolSize()
           
 int getMaxPoolSize()
           
 int getQueueSize()
           
 ThreadPoolExecutor getThreadPoolExecutor()
           
 BlockingQueue<Runnable> getThreadPoolQueue()
           
 void setCorePoolSize(int corePoolSize)
           
 void setMaxPoolSize(int maxPoolSize)
           
 void setQueueSize(int queueSize)
           
 void setThreadPoolExecutor(ThreadPoolExecutor threadPoolExecutor)
           
 void setThreadPoolQueue(BlockingQueue<Runnable> threadPoolQueue)
           
protected  void startExecutingJobs()
           
protected  void stopExecutingJobs()
           
 
从类 org.activiti.engine.impl.jobexecutor.JobExecutor 继承的方法
ensureCleanup, ensureInitialization, getAcquireJobsCmd, getCommandExecutor, getLockOwner, getLockTimeInMillis, getMaxJobsPerAcquisition, getName, getRejectedJobsHandler, getWaitTimeInMillis, isActive, isAutoActivate, jobWasAdded, setAcquireJobsCmd, setAutoActivate, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxJobsPerAcquisition, setRejectedJobsHandler, setWaitTimeInMillis, shutdown, start, startJobAcquisitionThread, stopJobAcquisitionThread
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

字段详细信息

queueSize

protected int queueSize

corePoolSize

protected int corePoolSize

threadPoolQueue

protected BlockingQueue<Runnable> threadPoolQueue

threadPoolExecutor

protected ThreadPoolExecutor threadPoolExecutor
构造方法详细信息

DefaultJobExecutor

public DefaultJobExecutor()
方法详细信息

startExecutingJobs

protected void startExecutingJobs()
指定者:
JobExecutor 中的 startExecutingJobs

stopExecutingJobs

protected void stopExecutingJobs()
指定者:
JobExecutor 中的 stopExecutingJobs

executeJobs

public void executeJobs(List<String> jobIds)
指定者:
JobExecutor 中的 executeJobs

getQueueSize

public int getQueueSize()

setQueueSize

public void setQueueSize(int queueSize)

getCorePoolSize

public int getCorePoolSize()

setCorePoolSize

public void setCorePoolSize(int corePoolSize)

getMaxPoolSize

public int getMaxPoolSize()

setMaxPoolSize

public void setMaxPoolSize(int maxPoolSize)

getThreadPoolQueue

public BlockingQueue<Runnable> getThreadPoolQueue()

setThreadPoolQueue

public void setThreadPoolQueue(BlockingQueue<Runnable> threadPoolQueue)

getThreadPoolExecutor

public ThreadPoolExecutor getThreadPoolExecutor()

setThreadPoolExecutor

public void setThreadPoolExecutor(ThreadPoolExecutor threadPoolExecutor)


Copyright © 2013 Alfresco. All rights reserved.