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
从类 org.activiti.engine.impl.jobexecutor.JobExecutor 继承的字段 |
acquireJobsCmd, acquireJobsRunnable, commandExecutor, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxJobsPerAcquisition, name, rejectedJobsHandler, waitTimeInMillis |
从类 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.