public interface PersistentJobRunner
Modifier and Type | Interface and Description |
---|---|
static interface |
PersistentJobRunner.CheckpointLock |
Modifier and Type | Method and Description |
---|---|
boolean |
hasLoaded()
Has the queue started yet?
|
PersistentJobRunner.CheckpointLock |
lock()
Obtain a lock which will prevent checkpointing until it is unlocked.
|
boolean |
newSalt()
For persistent requests, return true if the bloom filter salt has changed when loading the
requests.
|
void |
queue(PersistentJob persistentJob,
int threadPriority)
Start a job immediately unless we are about to write a checkpoint.
|
void |
queueInternal(PersistentJob job)
Start an "internal" job.
|
void |
queueInternal(PersistentJob job,
int threadPriority)
Start an "internal" job.
|
void |
queueNormalOrDrop(PersistentJob persistentJob)
Queue the job at low thread priority or drop it if persistence is disabled.
|
void |
setCheckpointASAP()
Commit ASAP.
|
boolean |
shuttingDown()
If true, the node is shutting down
|
void queue(PersistentJob persistentJob, int threadPriority) throws PersistenceDisabledException
persistentJob
- The job to run now or after the checkpoint.threadPriority
- The priority of the job.PersistenceDisabledException
- If persistence is disabled.void queueNormalOrDrop(PersistentJob persistentJob)
void queueInternal(PersistentJob job, int threadPriority) throws PersistenceDisabledException
job
- PersistenceDisabledException
void queueInternal(PersistentJob job)
job
- void setCheckpointASAP()
boolean hasLoaded()
PersistentJobRunner.CheckpointLock lock() throws PersistenceDisabledException
PersistenceDisabledException
- If we are unable to lock because the system is shutting
down.boolean newSalt()
boolean shuttingDown()