jetbrains.exodus.core.execution

Class DelegatingJobProcessor<T extends JobProcessorAdapter>

java.lang.Object

jetbrains.exodus.core.execution.JobProcessorAdapter

jetbrains.exodus.core.execution.DelegatingJobProcessor<T>

All Implemented Interfaces:

JobProcessor

public class DelegatingJobProcessor<T extends JobProcessorAdapter>
extends JobProcessorAdapter

Field Summary

Fields

Modifier and Type	Field and Description
protected T	delegate

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

exceptionHandler, finished, jobFinishedHandlers, jobStartingHandlers, started

Constructor Summary

Constructors

Constructor and Description
DelegatingJobProcessor(T delegate)

Method Summary

Modifier and Type	Method and Description
void	finish()
@Nullable Job	getCurrentJob()
long	getCurrentJobStartedAt()
T	getDelegate()
@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)
void	start()
java.lang.String	toString()
void	waitForJobs(long spinTimeout)
void	waitForTimedJobs(long spinTimeout)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

delegate

protected final T extends JobProcessorAdapter delegate

Constructor Detail

DelegatingJobProcessor

public DelegatingJobProcessor(@NotNull
                              T delegate)

Method Detail

getDelegate

public T getDelegate()

start

public void start()

finish

public void finish()

Specified by:

finish in interface JobProcessor

Overrides:

finish in class JobProcessorAdapter

pendingJobs

public int pendingJobs()

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

getCurrentJob

@Nullable
public @Nullable Job getCurrentJob()

getCurrentJobStartedAt

public long getCurrentJobStartedAt()

getPendingJobs

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

pendingTimedJobs

public int pendingTimedJobs()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

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

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