jetbrains.exodus.core.execution

Class ThreadJobProcessor

java.lang.Object

jetbrains.exodus.core.execution.JobProcessorAdapter

jetbrains.exodus.core.execution.JobProcessorQueueAdapter

jetbrains.exodus.core.execution.ThreadJobProcessor

All Implemented Interfaces:

JobProcessor

public class ThreadJobProcessor
extends JobProcessorQueueAdapter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ThreadJobProcessor.ThreadCreator

Field Summary

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

awake, CONCURRENT_QUEUE_PROPERTY

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

exceptionHandler, finished, jobFinishedHandlers, jobStartingHandlers, started

Constructor Summary

Constructors

Constructor and Description
ThreadJobProcessor(@NotNull java.lang.String name)
ThreadJobProcessor(@NotNull java.lang.String name, ThreadJobProcessor.ThreadCreator creator)

Method Summary

Modifier and Type	Method and Description
protected void	executeJob(@Nullable Job job)
void	finish() Signals that the processor to finish and waits until it finishes.
long	getId()
java.lang.String	getName()
boolean	isCurrentThread()
boolean	queueFinish()
void	run()
void	start() Starts processor thread.
java.lang.String	toString()
void	waitUntilFinished()

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

clearQueues, doJobs, doTimedJobs, getCurrentJob, getCurrentJobStartedAt, getPendingJobs, pendingJobs, pendingTimedJobs, push, pushAt, queueLowest, queueLowestTimed, waitForJobs

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

afterProcessingJob, beforeProcessingJob, 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, wait, wait, wait

Constructor Detail

ThreadJobProcessor

public ThreadJobProcessor(@NotNull
                          @NotNull java.lang.String name)

ThreadJobProcessor

public ThreadJobProcessor(@NotNull
                          @NotNull java.lang.String name,
                          @Nullable
                          ThreadJobProcessor.ThreadCreator creator)

Method Detail

start

public void start()

Starts processor thread.

finish

public void finish()

Signals that the processor to finish and waits until it finishes.

Specified by:

finish in interface JobProcessor

Overrides:

finish in class JobProcessorAdapter

queueFinish

public boolean queueFinish()

waitUntilFinished

public void waitUntilFinished()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getName

public java.lang.String getName()

getId

public long getId()

isCurrentThread

public boolean isCurrentThread()

run

public final void run()

executeJob

protected void executeJob(@Nullable
                          @Nullable Job job)

Overrides:

executeJob in class JobProcessorAdapter