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

Class AcquireTimerJobsRunnable

java.lang.Object

org.flowable.job.service.impl.asyncexecutor.AcquireTimerJobsRunnable

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

TenantAwareAcquireTimerJobsRunnable

public class AcquireTimerJobsRunnable
extends Object
implements Runnable

Author:

Tijs Rademakers, Joram Barrez, Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final AsyncExecutor	asyncExecutor
protected CommandExecutor	commandExecutor
protected AcquireJobsRunnableConfiguration	configuration
protected boolean	isInterrupted
protected final AtomicBoolean	isWaiting
protected final JobManager	jobManager
protected final AcquireTimerLifecycleListener	lifecycleListener
protected LockManager	lockManager
protected final Object	MONITOR
protected final int	moveExecutorPoolSize
protected ExecutorService	moveTimerJobsExecutorService

Constructor Summary

Constructors

Constructor	Description
AcquireTimerJobsRunnable(AsyncExecutor asyncExecutor, JobManager jobManager, int moveExecutorPoolSize)
AcquireTimerJobsRunnable(AsyncExecutor asyncExecutor, JobManager jobManager, AcquireTimerLifecycleListener lifecycleListener, AcquireJobsRunnableConfiguration configuration, int moveExecutorPoolSize)

Method Summary

Modifier and Type	Method	Description
protected LockManager	createLockManager(CommandExecutor commandExecutor)
protected void	createTimerMoveExecutorService(String threadName)
protected long	executeAcquireAndMoveCycle()
protected void	executeMoveTimerJobsToExecutableJobs(List<TimerJobEntity> timerJobs)
protected String	getEngineName()
protected void	logOptimisticLockingException(FlowableOptimisticLockingException optimisticLockingException)
void	run()
void	setConfiguration(AcquireJobsRunnableConfiguration configuration)
protected void	sleep(long millisToWait)
void	stop()
protected void	unlockTimerJobs(Collection<TimerJobEntity> timerJobs)

Methods inherited from class java.lang.Object

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

Field Details

asyncExecutor

protected final AsyncExecutor asyncExecutor

jobManager

protected final JobManager jobManager

lifecycleListener

protected final AcquireTimerLifecycleListener lifecycleListener

configuration

protected AcquireJobsRunnableConfiguration configuration

lockManager

protected LockManager lockManager

isInterrupted

protected volatile boolean isInterrupted

MONITOR

protected final Object MONITOR

isWaiting

protected final AtomicBoolean isWaiting

moveExecutorPoolSize

protected final int moveExecutorPoolSize

moveTimerJobsExecutorService

protected ExecutorService moveTimerJobsExecutorService

commandExecutor

protected CommandExecutor commandExecutor

Constructor Details

AcquireTimerJobsRunnable

public AcquireTimerJobsRunnable(AsyncExecutor asyncExecutor,
 JobManager jobManager,
 int moveExecutorPoolSize)

AcquireTimerJobsRunnable

public AcquireTimerJobsRunnable(AsyncExecutor asyncExecutor,
 JobManager jobManager,
 AcquireTimerLifecycleListener lifecycleListener,
 AcquireJobsRunnableConfiguration configuration,
 int moveExecutorPoolSize)

Method Details

run

public void run()

Specified by:

run in interface Runnable

createLockManager

protected LockManager createLockManager(CommandExecutor commandExecutor)

createTimerMoveExecutorService

protected void createTimerMoveExecutorService(String threadName)

executeAcquireAndMoveCycle

protected long executeAcquireAndMoveCycle()

executeMoveTimerJobsToExecutableJobs

protected void executeMoveTimerJobsToExecutableJobs(List<TimerJobEntity> timerJobs)

logOptimisticLockingException

protected void logOptimisticLockingException(FlowableOptimisticLockingException optimisticLockingException)

sleep

protected void sleep(long millisToWait)

getEngineName

protected String getEngineName()

unlockTimerJobs

protected void unlockTimerJobs(Collection<TimerJobEntity> timerJobs)

stop

public void stop()

setConfiguration

public void setConfiguration(AcquireJobsRunnableConfiguration configuration)