jetbrains.exodus.core.execution

Interface JobProcessor

All Known Implementing Classes:

DelegatingJobProcessor, JobProcessorAdapter, JobProcessorQueueAdapter, ThreadJobProcessor

public interface JobProcessor

Method Summary

Modifier and Type	Method and Description
void	afterProcessingJob(@NotNull Job job)
void	beforeProcessingJob(@NotNull Job job)
void	finish()
@Nullable Job	getCurrentJob()
long	getCurrentJobStartedAt()
@Nullable JobProcessorExceptionHandler	getExceptionHandler()
@NotNull java.lang.Iterable<Job>	getPendingJobs()
boolean	isFinished()
boolean	isSuspended()
int	pendingJobs()
int	pendingTimedJobs()
boolean	queue(Job job)
boolean	queue(Job job, Priority priority)
Job	queueAt(Job job, long millis)
Job	queueIn(Job job, long millis)
void	resume()
void	setExceptionHandler(@Nullable JobProcessorExceptionHandler handler)
void	start()
void	suspend()
void	waitForJobs(long spinTimeout)
void	waitForTimedJobs(long spinTimeout)

Method Detail

start

void start()

finish

void finish()

isFinished

boolean isFinished()

setExceptionHandler

void setExceptionHandler(@Nullable
                         @Nullable JobProcessorExceptionHandler handler)

getExceptionHandler

@Nullable
@Nullable JobProcessorExceptionHandler getExceptionHandler()

queue

boolean queue(Job job)

queue

boolean queue(Job job,
              Priority priority)

queueAt

Job queueAt(Job job,
            long millis)

queueIn

Job queueIn(Job job,
            long millis)

pendingJobs

int pendingJobs()

pendingTimedJobs

int pendingTimedJobs()

waitForJobs

void waitForJobs(long spinTimeout)

waitForTimedJobs

void waitForTimedJobs(long spinTimeout)

suspend

void suspend()
      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

resume

void resume()

isSuspended

boolean isSuspended()

beforeProcessingJob

void beforeProcessingJob(@NotNull
                         @NotNull Job job)

afterProcessingJob

void afterProcessingJob(@NotNull
                        @NotNull Job job)

getCurrentJob

@Nullable
@Nullable Job getCurrentJob()

getCurrentJobStartedAt

long getCurrentJobStartedAt()

getPendingJobs

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