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 JobServiceConfiguration	jobServiceConfiguration

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	executeJob(boolean unlock)
protected void	handleFailedJob(Throwable exception)
protected boolean	lockJob()
void	run()
protected void	runInternally()
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

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)

Method Details

run

public void run()

Specified by:

run in interface Runnable

runInternally

protected void runInternally()

executeJob

protected void executeJob(boolean unlock)

unlockJobIfNeeded

protected void unlockJobIfNeeded()

lockJob

protected boolean lockJob()

unacquireJob

protected void unacquireJob()

handleFailedJob

protected void handleFailedJob(Throwable exception)