alluxio.util

Class ThreadUtils

java.lang.Object

alluxio.util.ThreadUtils

public final class ThreadUtils
extends Object

Utility method for working with threads.

Method Summary

Modifier and Type	Method and Description
static String	formatStackTrace(Thread thread)
static String	getCurrentThreadIdentifier()
static String	getThreadIdentifier(Thread thread)
static void	logAllThreads() Logs a stack trace for all threads currently running in the JVM, similar to jstack.
static void	shutdownAndAwaitTermination(ExecutorService pool, long timeoutMs) From https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html The following method shuts down an ExecutorService in two phases, first by calling shutdown to reject incoming tasks, and then calling shutdownNow, if necessary, to cancel any lingering tasks.

Methods inherited from class java.lang.Object

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

Method Detail

formatStackTrace

public static String formatStackTrace(Thread thread)

Parameters:

thread - a thread

Returns:

a human-readable representation of the thread's stack trace

logAllThreads

public static void logAllThreads()

Logs a stack trace for all threads currently running in the JVM, similar to jstack.

shutdownAndAwaitTermination

public static void shutdownAndAwaitTermination(ExecutorService pool,
                                               long timeoutMs)

From https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html The following method shuts down an ExecutorService in two phases, first by calling shutdown to reject incoming tasks, and then calling shutdownNow, if necessary, to cancel any lingering tasks.

Parameters:

pool - the executor service to shutdown

timeoutMs - how long to wait for the service to shut down

getCurrentThreadIdentifier

public static String getCurrentThreadIdentifier()

Returns:

a string representation of the current thread

getThreadIdentifier

public static String getThreadIdentifier(Thread thread)

Parameters:

thread - the thread

Returns:

a string representation of the given thread