public class SpringJobExecutor extends JobExecutor
This is a spring based implementation of the JobExecutor
using spring
abstraction TaskExecutor
for performing background task execution.
The idea behind this implementation is to externalize the configuration of the task executor, so it can leverage to Application servers controller thread pools, for example using the commonj API. The use of unmanaged thread in application servers is discouraged by the Java EE spec.
acquireJobsCmd, acquireJobsRunnable, clockReader, commandExecutor, isActive, isAutoActivate, jobAcquisitionThread, lockOwner, lockTimeInMillis, maxJobsPerAcquisition, name, rejectedJobsHandler, waitTimeInMillis
Constructor and Description |
---|
SpringJobExecutor() |
SpringJobExecutor(org.springframework.core.task.TaskExecutor taskExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
executeJobs(List<String> jobIds) |
org.springframework.core.task.TaskExecutor |
getTaskExecutor() |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
Required spring injected
TaskExecutor implementation that will be
used to execute runnable jobs. |
protected void |
startExecutingJobs() |
protected void |
stopExecutingJobs() |
ensureCleanup, ensureInitialization, getAcquireJobsCmd, getAcquireJobsRunnable, getCommandExecutor, getCurrentTime, getLockOwner, getLockTimeInMillis, getMaxJobsPerAcquisition, getName, getRejectedJobsHandler, getWaitTimeInMillis, isActive, isAutoActivate, jobDone, jobDone, jobWasAdded, setAcquireJobsCmd, setAcquireJobsRunnable, setAutoActivate, setClockReader, setCommandExecutor, setLockOwner, setLockTimeInMillis, setMaxJobsPerAcquisition, setRejectedJobsHandler, setWaitTimeInMillis, shutdown, start, startJobAcquisitionThread, stopJobAcquisitionThread
public SpringJobExecutor()
public SpringJobExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
public org.springframework.core.task.TaskExecutor getTaskExecutor()
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
TaskExecutor
implementation that will be
used to execute runnable jobs.taskExecutor
- public void executeJobs(List<String> jobIds)
executeJobs
in class JobExecutor
protected void startExecutingJobs()
startExecutingJobs
in class JobExecutor
protected void stopExecutingJobs()
stopExecutingJobs
in class JobExecutor
Copyright © 2016 Alfresco. All rights reserved.