Package org.flowable.spring.job.service

Class SpringAsyncExecutor

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.AbstractAsyncExecutor

org.flowable.job.service.impl.asyncexecutor.DefaultAsyncJobExecutor

org.flowable.spring.job.service.SpringAsyncExecutor

All Implemented Interfaces:

AsyncExecutor

Direct Known Subclasses:

SpringAsyncHistoryExecutor

public class SpringAsyncExecutor
extends DefaultAsyncJobExecutor

This is an AsyncExecutor implementation which allows invoking a custom job rejected jobs handler.

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.

Author:

Pablo Ganga, Joram Barrez

Nested Class Summary

Nested classes/interfaces inherited from class org.flowable.job.service.impl.asyncexecutor.AbstractAsyncExecutor

AbstractAsyncExecutor.AcquireAsyncJobsDueRunnableConfiguration, AbstractAsyncExecutor.AcquireTimerRunnableConfiguration

Field Summary

Fields

Modifier and Type	Field	Description
protected SpringRejectedJobsHandler	rejectedJobsHandler

Fields inherited from class org.flowable.job.service.impl.asyncexecutor.DefaultAsyncJobExecutor

asyncJobAcquisitionThread, resetExpiredJobThread, shutdownTaskExecutor, taskExecutor, timerJobAcquisitionThread

Fields inherited from class org.flowable.job.service.impl.asyncexecutor.AbstractAsyncExecutor

asyncJobsDueLifecycleListener, asyncJobsDueRunnable, asyncRunnableExecutionExceptionHandler, configuration, executeAsyncRunnableFactory, isActive, isAutoActivate, jobEntityManager, jobServiceConfiguration, resetExpiredJobsRunnable, temporaryJobQueue, timerJobRunnable, timerLifecycleListener

Constructor Summary

Constructors

Constructor	Description
SpringAsyncExecutor()
SpringAsyncExecutor(AsyncJobExecutorConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
boolean	executeAsyncJob(JobInfo job)	Offers the provided JobInfo to this AsyncExecutor instance to execute.
SpringRejectedJobsHandler	getRejectedJobsHandler()
protected void	initAsyncJobExecutionThreadPool()
void	setRejectedJobsHandler(SpringRejectedJobsHandler rejectedJobsHandler)	SpringRejectedJobsHandler implementation that will be used when jobs were rejected by the task executor.

Methods inherited from class org.flowable.job.service.impl.asyncexecutor.DefaultAsyncJobExecutor

createResetExpiredJobsRunnable, executeAsyncJob, getAsyncJobAcquisitionThread, getResetExpiredJobThread, getTaskExecutor, getTimerJobAcquisitionThread, isAsyncJobAcquisitionEnabled, isResetExpiredJobEnabled, isTimerJobAcquisitionEnabled, isUnlockOwnedJobs, sendRejectedEvent, setAsyncJobAcquisitionEnabled, setAsyncJobAcquisitionThread, setResetExpiredJobEnabled, setResetExpiredJobThread, setTaskExecutor, setTimerJobAcquisitionEnabled, setTimerJobAcquisitionThread, setUnlockOwnedJobs, shutdownAdditionalComponents, startAdditionalComponents, startJobAcquisitionThread, startResetExpiredJobsThread, startTimerAcquisitionThread, stopExecutingAsyncJobs, stopJobAcquisitionThread, stopResetExpiredJobsThread, stopTimerAcquisitionThread, unacquireJobAfterRejection

Methods inherited from class org.flowable.job.service.impl.asyncexecutor.AbstractAsyncExecutor

createRunnableForJob, executeTemporaryJobs, getAsyncJobLockTimeInMillis, getAsyncJobsDueLifecycleListener, getAsyncJobsDueRunnable, getAsyncJobsGlobalLockPollRate, getAsyncJobsGlobalLockWaitTime, getAsyncRunnableExecutionExceptionHandler, getConfiguration, getDefaultAsyncJobAcquireWaitTimeInMillis, getDefaultQueueSizeFullWaitTimeInMillis, getDefaultTimerJobAcquireWaitTimeInMillis, getExecuteAsyncRunnableFactory, getGlobalAcquireLockPrefix, getJobServiceConfiguration, getLockOwner, getMaxAsyncJobsDuePerAcquisition, getMaxTimerJobsPerAcquisition, getMoveTimerExecutorPoolSize, getResetExpiredJobsInterval, getResetExpiredJobsPageSize, getResetExpiredJobsRunnable, getTenantId, getTimerJobRunnable, getTimerLifecycleListener, getTimerLockPollRate, getTimerLockTimeInMillis, getTimerLockWaitTime, initializeJobEntityManager, initializeRunnables, isActive, isAutoActivate, isGlobalAcquireLockEnabled, isTimerRunnableNeeded, setAcquireRunnableThreadName, setAsyncJobLockTimeInMillis, setAsyncJobsDueLifecycleListener, setAsyncJobsDueRunnable, setAsyncJobsGlobalLockPollRate, setAsyncJobsGlobalLockWaitTime, setAsyncRunnableExecutionExceptionHandler, setAutoActivate, setConfiguration, setDefaultAsyncJobAcquireWaitTimeInMillis, setDefaultQueueSizeFullWaitTimeInMillis, setDefaultTimerJobAcquireWaitTimeInMillis, setExecuteAsyncRunnableFactory, setGlobalAcquireLockEnabled, setGlobalAcquireLockPrefix, setJobEntityManager, setJobServiceConfiguration, setLockOwner, setMaxAsyncJobsDuePerAcquisition, setMaxTimerJobsPerAcquisition, setMoveTimerExecutorPoolSize, setResetExpiredJobsInterval, setResetExpiredJobsPageSize, setResetExpiredJobsRunnable, setResetExpiredRunnableName, setTenantId, setTimerJobRunnable, setTimerLifecycleListener, setTimerLockPollRate, setTimerLockTimeInMillis, setTimerLockWaitTime, setTimerRunnableNeeded, shutdown, start, stopRunnables, unlockOwnedJobs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

rejectedJobsHandler

protected SpringRejectedJobsHandler rejectedJobsHandler

Constructor Details

SpringAsyncExecutor

public SpringAsyncExecutor()

SpringAsyncExecutor

public SpringAsyncExecutor(AsyncJobExecutorConfiguration configuration)

Method Details

getRejectedJobsHandler

public SpringRejectedJobsHandler getRejectedJobsHandler()

setRejectedJobsHandler

public void setRejectedJobsHandler(SpringRejectedJobsHandler rejectedJobsHandler)

SpringRejectedJobsHandler implementation that will be used when jobs were rejected by the task executor.

Parameters:

rejectedJobsHandler -

executeAsyncJob

public boolean executeAsyncJob(JobInfo job)

Description copied from interface: AsyncExecutor

Offers the provided JobInfo to this AsyncExecutor instance to execute. If the offering does not work for some reason, false will be returned (For example when the job queue is full in the DefaultAsyncJobExecutor).

Specified by:

executeAsyncJob in interface AsyncExecutor

Overrides:

executeAsyncJob in class AbstractAsyncExecutor

initAsyncJobExecutionThreadPool

protected void initAsyncJobExecutionThreadPool()

Overrides:

initAsyncJobExecutionThreadPool in class DefaultAsyncJobExecutor