
public abstract class MultiThreadDelegatingJobProcessor
extends JobProcessorAdapter

Nested Classes
Modifier and Type	Class	Description
`public class`	`MultiThreadDelegatingJobProcessor.Companion`

Fields
Modifier and Type	Field	Description
`private final Array<Job>`	`currentJobs`
`private final Boolean`	`isDispatcherThread`
`private final Integer`	`threadCount`
`private final AtomicBoolean`	`started`
`private final AtomicBoolean`	`finished`
`private final JobProcessorExceptionHandler`	`exceptionHandler`
`private final Array<JobHandler>`	`jobStartingHandlers`
`private final Array<JobHandler>`	`jobFinishedHandlers`

Modifier and Type	Method	Description
`final Array<Job>`	`getCurrentJobs()`
`final Boolean`	`getIsDispatcherThread()`
`final Integer`	`getThreadCount()`
`final <ERROR CLASS>`	`forEachSubProcessor(Function1<ThreadJobProcessor, Unit> action)`
`Unit`	`setExceptionHandler(JobProcessorExceptionHandler handler)`
`<ERROR CLASS>`	`waitForJobs(Long spinTimeout)`
`<ERROR CLASS>`	`waitForTimedJobs(Long spinTimeout)`
`<ERROR CLASS>`	`suspend()`
`<ERROR CLASS>`	`resume()`
`Job`	`getCurrentJob()`
`Long`	`getCurrentJobStartedAt()`
`Iterable<Job>`	`getPendingJobs()`
`Integer`	`pendingTimedJobs()`
`Unit`	`start()`
`Unit`	`finish()`
`Integer`	`pendingJobs()`

Methods inherited from class jetbrains.exodus.core.execution.MultiThreadDelegatingJobProcessor
afterProcessingJob, beforeProcessingJob, executeJob, getExceptionHandler, handleThrowable, isFinished, isSuspended, processorFinished, processorStarted, queue, queue, queueAt, queueIn, waitForLatchJob, waitForLatchJob
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

 final <ERROR CLASS> forEachSubProcessor(Function1<ThreadJobProcessor, Unit> action)

 Unit setExceptionHandler(JobProcessorExceptionHandler handler)

 <ERROR CLASS> waitForJobs(Long spinTimeout)

 <ERROR CLASS> waitForTimedJobs(Long spinTimeout)

Class MultiThreadDelegatingJobProcessor