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

Class AcquireAsyncJobsDueRunnable

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.AcquireAsyncJobsDueRunnable

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

TenantAwareAcquireAsyncJobsDueRunnable

public class AcquireAsyncJobsDueRunnable
extends Object
implements Runnable

Author:

Tijs Rademakers, Joram Barrez, Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final AsyncExecutor	asyncExecutor
protected AcquireJobsRunnableConfiguration	configuration
protected boolean	isInterrupted
protected final AtomicBoolean	isWaiting
protected final JobInfoEntityManager<? extends JobInfoEntity>	jobEntityManager
protected AcquireAsyncJobsDueLifecycleListener	lifecycleListener
protected LockManager	lockManager
protected final Object	MONITOR
protected String	name

Constructor Summary

Constructors

Constructor	Description
AcquireAsyncJobsDueRunnable(String name, AsyncExecutor asyncExecutor, JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager, AcquireAsyncJobsDueLifecycleListener lifecycleListener, AcquireJobsRunnableConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
protected long	acquireAndExecuteJobs(CommandExecutor commandExecutor, int remainingCapacity)
protected LockManager	createLockManager(CommandExecutor commandExecutor)
protected long	executeAcquireCycle(CommandExecutor commandExecutor)
protected String	getEngineName()
AcquireAsyncJobsDueLifecycleListener	getLifecycleListener()
protected List<JobInfoEntity>	offerJobs(List<? extends JobInfoEntity> acquiredJobs)
void	run()
void	setConfiguration(AcquireJobsRunnableConfiguration configuration)
void	setLifecycleListener(AcquireAsyncJobsDueLifecycleListener lifecycleListener)
protected void	sleep(long millisToWait)
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

name

protected String name

asyncExecutor

protected final AsyncExecutor asyncExecutor

jobEntityManager

protected final JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager

lifecycleListener

protected AcquireAsyncJobsDueLifecycleListener lifecycleListener

configuration

protected AcquireJobsRunnableConfiguration configuration

lockManager

protected LockManager lockManager

isInterrupted

protected volatile boolean isInterrupted

MONITOR

protected final Object MONITOR

isWaiting

protected final AtomicBoolean isWaiting

Constructor Details

AcquireAsyncJobsDueRunnable

public AcquireAsyncJobsDueRunnable(String name,
 AsyncExecutor asyncExecutor,
 JobInfoEntityManager<? extends JobInfoEntity> jobEntityManager,
 AcquireAsyncJobsDueLifecycleListener lifecycleListener,
 AcquireJobsRunnableConfiguration configuration)

Method Details

run

public void run()

Specified by:

run in interface Runnable

createLockManager

protected LockManager createLockManager(CommandExecutor commandExecutor)

executeAcquireCycle

protected long executeAcquireCycle(CommandExecutor commandExecutor)

acquireAndExecuteJobs

protected long acquireAndExecuteJobs(CommandExecutor commandExecutor,
 int remainingCapacity)

offerJobs

protected List<JobInfoEntity> offerJobs(List<? extends JobInfoEntity> acquiredJobs)

stop

public void stop()

sleep

protected void sleep(long millisToWait)

getEngineName

protected String getEngineName()

getLifecycleListener

public AcquireAsyncJobsDueLifecycleListener getLifecycleListener()

setLifecycleListener

public void setLifecycleListener(AcquireAsyncJobsDueLifecycleListener lifecycleListener)

setConfiguration

public void setConfiguration(AcquireJobsRunnableConfiguration configuration)