org.apache.hadoop.hbase.util

Class Threads

java.lang.Object

org.apache.hadoop.hbase.util.Threads

@InterfaceAudience.Private
public class Threads
extends java.lang.Object

Thread Utility

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	LOG
static java.lang.Thread.UncaughtExceptionHandler	LOGGING_EXCEPTION_HANDLER

Constructor Summary

Constructors

Constructor and Description
Threads()

Method Summary

Modifier and Type	Method and Description
static java.util.concurrent.ThreadPoolExecutor	getBoundedCachedThreadPool(int maxCachedThread, long timeout, java.util.concurrent.TimeUnit unit, java.util.concurrent.ThreadFactory threadFactory) Create a new CachedThreadPool with a bounded number as the maximum thread size in the pool.
static java.util.concurrent.ThreadFactory	getNamedThreadFactory(java.lang.String prefix) Returns a ThreadFactory that names each created thread uniquely, with a common prefix.
static java.util.concurrent.ThreadFactory	newDaemonThreadFactory(java.lang.String prefix) Same as {#newDaemonThreadFactory(String, UncaughtExceptionHandler)}, without setting the exception handler.
static java.util.concurrent.ThreadFactory	newDaemonThreadFactory(java.lang.String prefix, java.lang.Thread.UncaughtExceptionHandler handler) Get a named ThreadFactory that just builds daemon threads.
static void	printThreadInfo(java.io.PrintStream stream, java.lang.String title) Print all of the thread's information and stack traces.
static java.lang.Thread	setDaemonThreadRunning(java.lang.Thread t) Utility method that sets name, daemon status and starts passed thread.
static java.lang.Thread	setDaemonThreadRunning(java.lang.Thread t, java.lang.String name) Utility method that sets name, daemon status and starts passed thread.
static java.lang.Thread	setDaemonThreadRunning(java.lang.Thread t, java.lang.String name, java.lang.Thread.UncaughtExceptionHandler handler) Utility method that sets name, daemon status and starts passed thread.
static void	setLoggingUncaughtExceptionHandler(java.lang.Thread t) Sets an UncaughtExceptionHandler for the thread which logs the Exception stack if the thread dies.
static void	shutdown(java.lang.Thread t) Shutdown passed thread using isAlive and join.
static void	shutdown(java.lang.Thread t, long joinwait) Shutdown passed thread using isAlive and join.
static void	sleep(long millis) If interrupted, just prints out the interrupt on STDOUT, resets interrupt and returns
static void	sleepWithoutInterrupt(long msToWait) Sleeps for the given amount of time even if interrupted.
static void	threadDumpingIsAlive(java.lang.Thread t)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Log LOG

LOGGING_EXCEPTION_HANDLER

public static final java.lang.Thread.UncaughtExceptionHandler LOGGING_EXCEPTION_HANDLER

Constructor Detail

Threads

public Threads()

Method Detail

setDaemonThreadRunning

public static java.lang.Thread setDaemonThreadRunning(java.lang.Thread t)

Utility method that sets name, daemon status and starts passed thread.

Parameters:

t - thread to run

Returns:

Returns the passed Thread t.

setDaemonThreadRunning

public static java.lang.Thread setDaemonThreadRunning(java.lang.Thread t,
                                                      java.lang.String name)

Utility method that sets name, daemon status and starts passed thread.

Parameters:

t - thread to frob

name - new name

Returns:

Returns the passed Thread t.

setDaemonThreadRunning

public static java.lang.Thread setDaemonThreadRunning(java.lang.Thread t,
                                                      java.lang.String name,
                                                      java.lang.Thread.UncaughtExceptionHandler handler)

Utility method that sets name, daemon status and starts passed thread.

Parameters:

t - thread to frob

name - new name

handler - A handler to set on the thread. Pass null if want to use default handler.

Returns:

Returns the passed Thread t.

shutdown

public static void shutdown(java.lang.Thread t)

Shutdown passed thread using isAlive and join.

Parameters:

t - Thread to shutdown

shutdown

public static void shutdown(java.lang.Thread t,
                            long joinwait)

Shutdown passed thread using isAlive and join.

Parameters:

joinwait - Pass 0 if we're to wait forever.

t - Thread to shutdown

threadDumpingIsAlive

public static void threadDumpingIsAlive(java.lang.Thread t)
                                 throws java.lang.InterruptedException

Parameters:

t - Waits on the passed thread to die dumping a threaddump every minute while its up.

Throws:

java.lang.InterruptedException

sleep

public static void sleep(long millis)

If interrupted, just prints out the interrupt on STDOUT, resets interrupt and returns

Parameters:

millis - How long to sleep for in milliseconds.

sleepWithoutInterrupt

public static void sleepWithoutInterrupt(long msToWait)

Sleeps for the given amount of time even if interrupted. Preserves the interrupt status.

Parameters:

msToWait - the amount of time to sleep in milliseconds

getBoundedCachedThreadPool

public static java.util.concurrent.ThreadPoolExecutor getBoundedCachedThreadPool(int maxCachedThread,
                                                                                 long timeout,
                                                                                 java.util.concurrent.TimeUnit unit,
                                                                                 java.util.concurrent.ThreadFactory threadFactory)

Create a new CachedThreadPool with a bounded number as the maximum thread size in the pool.

Parameters:

maxCachedThread - the maximum thread could be created in the pool

timeout - the maximum time to wait

unit - the time unit of the timeout argument

threadFactory - the factory to use when creating new threads

Returns:

threadPoolExecutor the cachedThreadPool with a bounded number as the maximum thread size in the pool.

getNamedThreadFactory

public static java.util.concurrent.ThreadFactory getNamedThreadFactory(java.lang.String prefix)

Returns a ThreadFactory that names each created thread uniquely, with a common prefix.

Parameters:

prefix - The prefix of every created Thread's name

Returns:

a ThreadFactory that names threads

newDaemonThreadFactory

public static java.util.concurrent.ThreadFactory newDaemonThreadFactory(java.lang.String prefix)

Same as {#newDaemonThreadFactory(String, UncaughtExceptionHandler)}, without setting the exception handler.

newDaemonThreadFactory

public static java.util.concurrent.ThreadFactory newDaemonThreadFactory(java.lang.String prefix,
                                                                        java.lang.Thread.UncaughtExceptionHandler handler)

Get a named ThreadFactory that just builds daemon threads.

Parameters:

prefix - name prefix for all threads created from the factory

handler - unhandles exception handler to set for all threads

Returns:

a thread factory that creates named, daemon threads with the supplied exception handler and normal priority

setLoggingUncaughtExceptionHandler

public static void setLoggingUncaughtExceptionHandler(java.lang.Thread t)

Sets an UncaughtExceptionHandler for the thread which logs the Exception stack if the thread dies.

printThreadInfo

public static void printThreadInfo(java.io.PrintStream stream,
                                   java.lang.String title)

Print all of the thread's information and stack traces. Wrapper around Hadoop's method.

Parameters:

stream - the stream to

title - a string title for the stack trace