Package org.camunda.bpm.engine.impl.jobexecutor

Class AcquireJobsRunnable

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

SequentialJobAcquisitionRunnable

public abstract class AcquireJobsRunnable
extends java.lang.Object
implements java.lang.Runnable

Author:

Thorben Lindhauer

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	isInterrupted
protected boolean	isJobAdded
protected java.util.concurrent.atomic.AtomicBoolean	isWaiting
protected JobExecutor	jobExecutor
protected java.lang.Object	MONITOR

Constructor Summary

Constructors

Constructor	Description
AcquireJobsRunnable(JobExecutor jobExecutor)

Method Summary

Modifier and Type	Method	Description
protected void	clearJobAddedNotification()
boolean	isJobAdded()
void	jobWasAdded()
void	stop()
protected void	suspendAcquisition(long millis)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Detail

jobExecutor

protected final JobExecutor jobExecutor

isInterrupted

protected volatile boolean isInterrupted

isJobAdded

protected volatile boolean isJobAdded

MONITOR

protected final java.lang.Object MONITOR

isWaiting

protected final java.util.concurrent.atomic.AtomicBoolean isWaiting

Constructor Detail

AcquireJobsRunnable

public AcquireJobsRunnable(JobExecutor jobExecutor)

Method Detail

suspendAcquisition

protected void suspendAcquisition(long millis)

stop

public void stop()

jobWasAdded

public void jobWasAdded()

clearJobAddedNotification

protected void clearJobAddedNotification()

isJobAdded

public boolean isJobAdded()