protected static class UnilateralSortMerger.SortingThread<E> extends UnilateralSortMerger.ThreadBase<E>
Thread.State, Thread.UncaughtExceptionHandler
queues
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
SortingThread(ExceptionHandler<IOException> exceptionHandler,
UnilateralSortMerger.CircularQueues<E> queues,
AbstractInvokable parentTask)
Creates a new sorting thread.
|
Modifier and Type | Method and Description |
---|---|
void |
go()
Entry point of the thread.
|
internalHandleException, isRunning, run, shutdown, uncaughtException
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public SortingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask)
exceptionHandler
- The exception handler to call for all exceptions.queues
- The queues used to pass buffers between the threads.parentTask
- The task that started this thread. If non-null, it is used to register
this thread.public void go() throws IOException
go
in class UnilateralSortMerger.ThreadBase<E>
IOException
- Exceptions that prohibit correct completion of the work may be thrown
by the thread.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.