public class AcquireJobsRunnableImpl extends Object implements AcquireJobsRunnable
Modifier and Type | Field and Description |
---|---|
protected boolean |
isInterrupted |
protected boolean |
isJobAdded |
protected AtomicBoolean |
isWaiting |
protected JobExecutor |
jobExecutor |
protected long |
millisToWait |
protected Object |
MONITOR |
Constructor and Description |
---|
AcquireJobsRunnableImpl(JobExecutor jobExecutor) |
Modifier and Type | Method and Description |
---|---|
long |
getMillisToWait() |
void |
jobWasAdded()
Called by the job executor when a new job was added by the
process engine to which this job executor belongs.
|
void |
run() |
void |
setMillisToWait(long millisToWait) |
void |
stop()
Called when the job executor is shutting down and the job
acquiring needs to be shut down too.
|
protected final JobExecutor jobExecutor
protected volatile boolean isInterrupted
protected volatile boolean isJobAdded
protected final Object MONITOR
protected final AtomicBoolean isWaiting
protected long millisToWait
public AcquireJobsRunnableImpl(JobExecutor jobExecutor)
public void stop()
AcquireJobsRunnable
stop
in interface AcquireJobsRunnable
public void jobWasAdded()
AcquireJobsRunnable
jobWasAdded
in interface AcquireJobsRunnable
public long getMillisToWait()
public void setMillisToWait(long millisToWait)
Copyright © 2016 Alfresco. All rights reserved.