alluxio.thread

Class AutopsyThread

java.lang.Object

java.lang.Thread

alluxio.thread.AutopsyThread

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

AbstractCatchupThread, UfsJournalCheckpointThread

public class AutopsyThread
extends Thread

This thread is able to capture uncaught exceptions from run() so other classes can check the status of the thread and know why it crashed.

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
AutopsyThread() Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	crashed() Checks if the thread has crashed.
Throwable	getError() Gets the crashing error.
void	onError(Throwable t) Handles the uncaught error on thread crashing.
void	setError(Throwable t) Sets the error before exiting.

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

AutopsyThread

public AutopsyThread()

Constructor.

Method Detail

crashed

public boolean crashed()

Checks if the thread has crashed.

Returns:

true if the thread crashed due to an uncaught exception

setError

public void setError(Throwable t)

Sets the error before exiting.

Parameters:

t - the crashing error

onError

public void onError(Throwable t)

Handles the uncaught error on thread crashing. By default, just log the error for further analysis.

Parameters:

t - the crashing error

getError

@Nullable
public Throwable getError()

Gets the crashing error.

Returns:

the error