org.apache.ignite.internal.processors.hadoop.impl.v2

Class HadoopDaemon

java.lang.Object

java.lang.Thread

org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopDaemon

All Implemented Interfaces:

Runnable

public class HadoopDaemon
extends Thread

Replacement for Hadoop org.apache.hadoop.util.Daemon class.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
HadoopDaemon() Construct a daemon thread.
HadoopDaemon(Runnable runnable) Construct a daemon thread.
HadoopDaemon(ThreadGroup grp, Runnable runnable) Construct a daemon thread to be part of a specified thread group.

Method Summary

Modifier and Type	Method and Description
static void	dequeueAndStopAll() Stops all the registered threads.
Runnable	getRunnable() Getter for the runnable.

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, run, 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

Constructor Detail

HadoopDaemon

public HadoopDaemon()

Construct a daemon thread.

HadoopDaemon

public HadoopDaemon(Runnable runnable)

Construct a daemon thread.

HadoopDaemon

public HadoopDaemon(ThreadGroup grp,
                    Runnable runnable)

Construct a daemon thread to be part of a specified thread group.

Method Detail

getRunnable

public Runnable getRunnable()

Getter for the runnable. May return this.

Returns:

the runnable

dequeueAndStopAll

public static void dequeueAndStopAll()

Stops all the registered threads.