jetbrains.exodus.core.execution

Class JobProcessorQueueAdapter

java.lang.Object

jetbrains.exodus.core.execution.JobProcessorAdapter

jetbrains.exodus.core.execution.JobProcessorQueueAdapter

All Implemented Interfaces:

JobProcessor

Direct Known Subclasses:

ThreadJobProcessor

public abstract class JobProcessorQueueAdapter
extends JobProcessorAdapter

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.Semaphore	awake
static java.lang.String	CONCURRENT_QUEUE_PROPERTY

Fields inherited from class jetbrains.exodus.core.execution.JobProcessorAdapter

exceptionHandler, finished, jobFinishedHandlers, jobStartingHandlers, started

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobProcessorQueueAdapter()

Method Summary

Modifier and Type	Method and Description
protected void	clearQueues()
protected void	doJobs()
protected void	doTimedJobs()
@Nullable Job	getCurrentJob()
long	getCurrentJobStartedAt()
@NotNull java.lang.Iterable<Job>	getPendingJobs()
int	pendingJobs()
int	pendingTimedJobs()
protected boolean	push(Job job, Priority priority)
protected Job	pushAt(Job job, long millis)
protected boolean	queueLowest(@NotNull Job job)
protected boolean	queueLowestTimed(@NotNull Job job)
protected boolean	waitForJobs()

Methods inherited from class jetbrains.exodus.core.execution.JobProcessorAdapter

afterProcessingJob, beforeProcessingJob, executeJob, finish, getExceptionHandler, isFinished, isSuspended, processorFinished, processorStarted, queue, queue, queueAt, queueIn, resume, setExceptionHandler, suspend, waitForJobs, waitForLatchJob, waitForLatchJob, waitForTimedJobs

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

start

Field Detail

CONCURRENT_QUEUE_PROPERTY

public static final java.lang.String CONCURRENT_QUEUE_PROPERTY

See Also:

Constant Field Values

awake

protected final java.util.concurrent.Semaphore awake

Constructor Detail

JobProcessorQueueAdapter

protected JobProcessorQueueAdapter()

Method Detail

queueLowest

protected boolean queueLowest(@NotNull
                              @NotNull Job job)

Specified by:

queueLowest in class JobProcessorAdapter

push

protected boolean push(Job job,
                       Priority priority)

Specified by:

push in class JobProcessorAdapter

pushAt

protected Job pushAt(Job job,
                     long millis)

Specified by:

pushAt in class JobProcessorAdapter

queueLowestTimed

protected boolean queueLowestTimed(@NotNull
                                   @NotNull Job job)

Specified by:

queueLowestTimed in class JobProcessorAdapter

pendingJobs

public int pendingJobs()

pendingTimedJobs

public int pendingTimedJobs()

getCurrentJob

@Nullable
public @Nullable Job getCurrentJob()

getCurrentJobStartedAt

public long getCurrentJobStartedAt()

getPendingJobs

@NotNull
public @NotNull java.lang.Iterable<Job> getPendingJobs()

doJobs

protected void doJobs()

clearQueues

protected void clearQueues()

doTimedJobs

protected void doTimedJobs()

waitForJobs

protected boolean waitForJobs()
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException