jetbrains.exodus.core.execution

Class MultiThreadDelegatingJobProcessor

java.lang.Object

jetbrains.exodus.core.execution.JobProcessorAdapter

jetbrains.exodus.core.execution.MultiThreadDelegatingJobProcessor

All Implemented Interfaces:

JobProcessor

public abstract class MultiThreadDelegatingJobProcessor
extends JobProcessorAdapter

Field Summary

Fields

Modifier and Type	Field and Description
protected ThreadJobProcessor[]	jobProcessors

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

exceptionHandler, finished, jobFinishedHandlers, jobStartingHandlers, started

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MultiThreadDelegatingJobProcessor(java.lang.String name, int threadCount)

Method Summary

Modifier and Type	Method and Description
void	finish()
@Nullable Job	getCurrentJob()
long	getCurrentJobStartedAt()
@NotNull java.lang.Iterable<Job>	getPendingJobs()
int	getThreadCount()
boolean	isDispatcherThread()
int	pendingJobs()
int	pendingTimedJobs()
protected void	processorFinished()
protected void	processorStarted()
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)
void	start()
void	waitForJobs(long spinTimeout)
void	waitForTimedJobs(long spinTimeout)

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

afterProcessingJob, beforeProcessingJob, executeJob, getExceptionHandler, isFinished, isSuspended, queue, queue, queueAt, queueIn, resume, setExceptionHandler, suspend, waitForLatchJob, waitForLatchJob

Methods inherited from class java.lang.Object

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

Field Detail

jobProcessors

protected final ThreadJobProcessor[] jobProcessors

Constructor Detail

MultiThreadDelegatingJobProcessor

protected MultiThreadDelegatingJobProcessor(java.lang.String name,
                                            int threadCount)

Method Detail

pushAt

protected Job pushAt(Job job,
                     long millis)

Specified by:

pushAt in class JobProcessorAdapter

waitForJobs

public void waitForJobs(long spinTimeout)

Specified by:

waitForJobs in interface JobProcessor

Overrides:

waitForJobs in class JobProcessorAdapter

waitForTimedJobs

public void waitForTimedJobs(long spinTimeout)

Specified by:

waitForTimedJobs in interface JobProcessor

Overrides:

waitForTimedJobs in class JobProcessorAdapter

queueLowest

protected boolean queueLowest(@NotNull
                              @NotNull Job job)

Specified by:

queueLowest in class JobProcessorAdapter

queueLowestTimed

protected boolean queueLowestTimed(@NotNull
                                   @NotNull Job job)

Specified by:

queueLowestTimed in class JobProcessorAdapter

getCurrentJob

@Nullable
public @Nullable Job getCurrentJob()

getCurrentJobStartedAt

public long getCurrentJobStartedAt()

getPendingJobs

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

pendingTimedJobs

public int pendingTimedJobs()

start

public void start()

processorStarted

protected final void processorStarted()

Overrides:

processorStarted in class JobProcessorAdapter

processorFinished

protected final void processorFinished()

Overrides:

processorFinished in class JobProcessorAdapter

finish

public void finish()

Specified by:

finish in interface JobProcessor

Overrides:

finish in class JobProcessorAdapter

isDispatcherThread

public boolean isDispatcherThread()

pendingJobs

public int pendingJobs()

getThreadCount

public int getThreadCount()

push

protected boolean push(Job job,
                       Priority priority)

Specified by:

push in class JobProcessorAdapter