org.apache.flink.runtime.operators.sort

Class UnilateralSortMerger.ThreadBase<E>

java.lang.Object

java.lang.Thread

org.apache.flink.runtime.operators.sort.UnilateralSortMerger.ThreadBase<E>

All Implemented Interfaces:

Runnable, Thread.UncaughtExceptionHandler

Direct Known Subclasses:

UnilateralSortMerger.ReadingThread, UnilateralSortMerger.SortingThread, UnilateralSortMerger.SpillingThread

Enclosing class:

UnilateralSortMerger<E>

protected abstract static class UnilateralSortMerger.ThreadBase<E>
extends Thread
implements Thread.UncaughtExceptionHandler

Base class for all working threads in this sort-merger. The specific threads for reading, sorting, spilling, merging, etc... extend this subclass.

The threads are designed to terminate themselves when the task they are set up to do is completed. Further more, they terminate immediately when the shutdown() method is called.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected UnilateralSortMerger.CircularQueues<E>	queues The queue of empty buffer that can be used for reading;

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ThreadBase(ExceptionHandler<IOException> exceptionHandler, String name, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask) Creates a new thread.

Method Summary

Modifier and Type	Method and Description
protected abstract void	go() Equivalent to the run() method.
protected void	internalHandleException(IOException ioex) Internally handles an exception and makes sure that this method returns without a problem.
boolean	isRunning() Checks whether this thread is still alive.
void	run() Implements exception handling and delegates to go().
void	shutdown() Forces an immediate shutdown of the thread.
void	uncaughtException(Thread t, Throwable e)

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

queues

protected final UnilateralSortMerger.CircularQueues<E> queues

The queue of empty buffer that can be used for reading;

Constructor Detail

ThreadBase

protected ThreadBase(ExceptionHandler<IOException> exceptionHandler,
                     String name,
                     UnilateralSortMerger.CircularQueues<E> queues,
                     AbstractInvokable parentTask)

Creates a new thread.

Parameters:

exceptionHandler - The exception handler to call for all exceptions.

name - The name of the thread.

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.

Method Detail

run

public void run()

Implements exception handling and delegates to go().

Specified by:

run in interface Runnable

Overrides:

run in class Thread

go

protected abstract void go()
                    throws IOException

Equivalent to the run() method.

Throws:

IOException - Exceptions that prohibit correct completion of the work may be thrown by the thread.

isRunning

public boolean isRunning()

Checks whether this thread is still alive.

Returns:

true, if the thread is alive, false otherwise.

shutdown

public void shutdown()

Forces an immediate shutdown of the thread. Looses any state and all buffers that the thread is currently working on. This terminates cleanly for the JVM, but looses intermediate results.

internalHandleException

protected final void internalHandleException(IOException ioex)

Internally handles an exception and makes sure that this method returns without a problem.

Parameters:

ioex - The exception to handle.

uncaughtException

public void uncaughtException(Thread t,
                              Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler