jetbrains.exodus.core.execution

Class JobProcessorAdapter

java.lang.Object

jetbrains.exodus.core.execution.JobProcessorAdapter

All Implemented Interfaces:

JobProcessor

Direct Known Subclasses:

DelegatingJobProcessor, JobProcessorQueueAdapter

public abstract class JobProcessorAdapter
extends java.lang.Object
implements JobProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected @Nullable JobProcessorExceptionHandler	exceptionHandler
protected java.util.concurrent.atomic.AtomicBoolean	finished
protected @Nullable jetbrains.exodus.core.execution.JobHandler[]	jobFinishedHandlers
protected @Nullable jetbrains.exodus.core.execution.JobHandler[]	jobStartingHandlers
protected java.util.concurrent.atomic.AtomicBoolean	started

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobProcessorAdapter()

Method Summary

Modifier and Type	Method and Description
void	afterProcessingJob(@NotNull Job job)
void	beforeProcessingJob(@NotNull Job job)
protected void	executeJob(@Nullable Job job)
void	finish()
@Nullable JobProcessorExceptionHandler	getExceptionHandler()
boolean	isFinished()
boolean	isSuspended()
protected void	processorFinished()
protected void	processorStarted()
protected abstract boolean	push(Job job, Priority priority)
protected abstract Job	pushAt(Job job, long millis)
boolean	queue(Job job) Queues a job for execution with the normal (default) priority.
boolean	queue(Job job, Priority priority) Queues a job for execution with specified priority.
Job	queueAt(Job job, long millis) Queues a job for execution at specified time.
Job	queueIn(Job job, long millis) Queues a job for execution in specified time.
protected abstract boolean	queueLowest(@NotNull Job job)
protected abstract boolean	queueLowestTimed(@NotNull Job job)
void	resume()
void	setExceptionHandler(@Nullable JobProcessorExceptionHandler handler)
void	suspend()
void	waitForJobs(long spinTimeout)
boolean	waitForLatchJob(LatchJob latchJob, long spinTimeout)
boolean	waitForLatchJob(LatchJob latchJob, long spinTimeout, Priority priority)
void	waitForTimedJobs(long spinTimeout)

Methods inherited from class java.lang.Object

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

Methods inherited from interface jetbrains.exodus.core.execution.JobProcessor

getCurrentJob, getCurrentJobStartedAt, getPendingJobs, pendingJobs, pendingTimedJobs, start

Field Detail

started

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

finished

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

exceptionHandler

@Nullable
protected @Nullable JobProcessorExceptionHandler exceptionHandler

jobStartingHandlers

@Nullable
protected @Nullable jetbrains.exodus.core.execution.JobHandler[] jobStartingHandlers

jobFinishedHandlers

@Nullable
protected @Nullable jetbrains.exodus.core.execution.JobHandler[] jobFinishedHandlers

Constructor Detail

JobProcessorAdapter

protected JobProcessorAdapter()

Method Detail

isFinished

public boolean isFinished()

Specified by:

isFinished in interface JobProcessor

setExceptionHandler

public void setExceptionHandler(@Nullable
                                @Nullable JobProcessorExceptionHandler handler)

Specified by:

setExceptionHandler in interface JobProcessor

getExceptionHandler

@Nullable
public @Nullable JobProcessorExceptionHandler getExceptionHandler()

Specified by:

getExceptionHandler in interface JobProcessor

queue

public final boolean queue(Job job)

Queues a job for execution with the normal (default) priority.

Specified by:

queue in interface JobProcessor

Parameters:

job - job to execute.

Returns:

true if the job was actually queued, else if it was merged with an equal job queued earlier and still not executed.

queue

public final boolean queue(Job job,
                           Priority priority)

Queues a job for execution with specified priority.

Specified by:

queue in interface JobProcessor

Parameters:

job - job to execute.

priority - priority if the job in the job queue.

Returns:

true if the job was actually queued, else if it was merged with an equal job queued earlier and still not executed.

queueAt

public final Job queueAt(Job job,
                         long millis)

Queues a job for execution at specified time.

Specified by:

queueAt in interface JobProcessor

Parameters:

job - the job.

millis - time to execute the job.

queueIn

public final Job queueIn(Job job,
                         long millis)

Queues a job for execution in specified time.

Specified by:

queueIn in interface JobProcessor

Parameters:

job - the job.

millis - execute the job in this time.

finish

public void finish()

Specified by:

finish in interface JobProcessor

waitForJobs

public void waitForJobs(long spinTimeout)

Specified by:

waitForJobs in interface JobProcessor

waitForTimedJobs

public void waitForTimedJobs(long spinTimeout)

Specified by:

waitForTimedJobs in interface JobProcessor

suspend

public void suspend()
             throws java.lang.InterruptedException

Specified by:

suspend in interface JobProcessor

Throws:

java.lang.InterruptedException

resume

public void resume()

Specified by:

resume in interface JobProcessor

isSuspended

public boolean isSuspended()

Specified by:

isSuspended in interface JobProcessor

beforeProcessingJob

public void beforeProcessingJob(@NotNull
                                @NotNull Job job)

Specified by:

beforeProcessingJob in interface JobProcessor

afterProcessingJob

public void afterProcessingJob(@NotNull
                               @NotNull Job job)

Specified by:

afterProcessingJob in interface JobProcessor

queueLowest

protected abstract boolean queueLowest(@NotNull
                                       @NotNull Job job)

queueLowestTimed

protected abstract boolean queueLowestTimed(@NotNull
                                            @NotNull Job job)

waitForLatchJob

public boolean waitForLatchJob(LatchJob latchJob,
                               long spinTimeout,
                               Priority priority)

waitForLatchJob

public boolean waitForLatchJob(LatchJob latchJob,
                               long spinTimeout)

push

protected abstract boolean push(Job job,
                                Priority priority)

pushAt

protected abstract Job pushAt(Job job,
                              long millis)

processorStarted

protected void processorStarted()

processorFinished

protected void processorFinished()

executeJob

protected void executeJob(@Nullable
                          @Nullable Job job)