org.camunda.bpm.engine.impl.jobexecutor

Class AcquireJobsRunnable

java.lang.Object

org.camunda.bpm.engine.impl.jobexecutor.AcquireJobsRunnable

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

SequentialJobAcquisitionRunnable

public class AcquireJobsRunnable
extends Object
implements Runnable

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isInterrupted
protected boolean	isJobAdded
protected AtomicBoolean	isWaiting
protected JobExecutor	jobExecutor
protected long	maxWait
protected long	millisToWait
protected Object	MONITOR
protected float	waitIncreaseFactor

Constructor Summary

Constructors

Constructor and Description
AcquireJobsRunnable(JobExecutor jobExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
long	getMaxWait()
long	getMillisToWait()
float	getWaitIncreaseFactor()
void	jobWasAdded()
void	run()
void	setMaxWait(long maxWait)
void	setMillisToWait(long millisToWait)
void	setWaitIncreaseFactor(float waitIncreaseFactor)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

jobExecutor

protected final JobExecutor jobExecutor

isInterrupted

protected volatile boolean isInterrupted

isJobAdded

protected volatile boolean isJobAdded

MONITOR

protected final Object MONITOR

isWaiting

protected final AtomicBoolean isWaiting

millisToWait

protected long millisToWait

waitIncreaseFactor

protected float waitIncreaseFactor

maxWait

protected long maxWait

Constructor Detail

AcquireJobsRunnable

public AcquireJobsRunnable(JobExecutor jobExecutor)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

jobWasAdded

public void jobWasAdded()

getMillisToWait

public long getMillisToWait()

setMillisToWait

public void setMillisToWait(long millisToWait)

getWaitIncreaseFactor

public float getWaitIncreaseFactor()

setWaitIncreaseFactor

public void setWaitIncreaseFactor(float waitIncreaseFactor)

getMaxWait

public long getMaxWait()

setMaxWait

public void setMaxWait(long maxWait)