Package org.flowable.job.service.impl.asyncexecutor

Class ExecuteAsyncRunnable

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.ExecuteAsyncRunnable

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

TenantAwareExecuteAsyncRunnable

public class ExecuteAsyncRunnable
extends Object
implements Runnable

Author:

Joram Barrez, Tijs Rademakers

Field Summary

Fields

Modifier and Type	Field	Description
protected List<AsyncRunnableExecutionExceptionHandler>	asyncRunnableExecutionExceptionHandlers
protected final JobInfo	job
protected JobInfoEntityManager<? extends JobInfoEntity>	jobEntityManager
protected final JobExecutionObservationProvider	jobExecutionObservationProvider
protected JobServiceConfiguration	jobServiceConfiguration

Constructor Summary

Constructors

Constructor	Description
ExecuteAsyncRunnable(JobInfo job, JobServiceConfiguration jobServiceConfiguration, JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager, AsyncRunnableExecutionExceptionHandler asyncRunnableExecutionExceptionHandler, JobExecutionObservationProvider jobExecutionObservationProvider)

Method Summary

Modifier and Type	Method	Description
protected void	executeJob(boolean unlock, JobExecutionObservation observation)
protected void	handleFailedJob(Throwable exception)
protected boolean	handleNontransactionalJob(NonTransactionalJobHandler jobHandler, boolean unlock)
protected void	handleTransactionalJob(boolean unlock)
protected boolean	lockJob(JobExecutionObservation observation)
void	run()
protected void	runInternally(JobExecutionObservation observation)
protected void	unacquireJob()
protected void	unlockJobIfNeeded()

Methods inherited from class java.lang.Object

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

Field Details

job

protected final JobInfo job

jobExecutionObservationProvider

protected final JobExecutionObservationProvider jobExecutionObservationProvider

jobServiceConfiguration

protected JobServiceConfiguration jobServiceConfiguration

jobEntityManager

protected JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager

asyncRunnableExecutionExceptionHandlers

protected List<AsyncRunnableExecutionExceptionHandler> asyncRunnableExecutionExceptionHandlers

Constructor Details

ExecuteAsyncRunnable

public ExecuteAsyncRunnable(JobInfo job,
 JobServiceConfiguration jobServiceConfiguration,
 JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager,
 AsyncRunnableExecutionExceptionHandler asyncRunnableExecutionExceptionHandler,
 JobExecutionObservationProvider jobExecutionObservationProvider)

Method Details

run

public void run()

Specified by:

run in interface Runnable

runInternally

protected void runInternally(JobExecutionObservation observation)

executeJob

protected void executeJob(boolean unlock,
 JobExecutionObservation observation)

handleTransactionalJob

protected void handleTransactionalJob(boolean unlock)

handleNontransactionalJob

protected boolean handleNontransactionalJob(NonTransactionalJobHandler jobHandler,
 boolean unlock)

unlockJobIfNeeded

protected void unlockJobIfNeeded()

lockJob

protected boolean lockJob(JobExecutionObservation observation)

unacquireJob

protected void unacquireJob()

handleFailedJob

protected void handleFailedJob(Throwable exception)