alluxio.master.transport

Class GrpcMessagingThread

java.lang.Object

java.lang.Thread

alluxio.master.transport.GrpcMessagingThread

All Implemented Interfaces:

Runnable

public class GrpcMessagingThread
extends Thread

A thread used for Grpc messaging and stores a GrpcMessagingContext for current thread. The context is storead in a WeakReference in order to allow the thread to be garbage collected. There is no GrpcMessagingContext associated with the thread when it is first created. It is the responsibility of thread creators to set the thread context when appropriate.

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
GrpcMessagingThread(Runnable target, String name) Constructs a new GrpcMessagingThread.

Method Summary

Modifier and Type	Method and Description
GrpcMessagingContext	getContext()
void	setContext(GrpcMessagingContext context) Sets the Grpc messaging context.

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

GrpcMessagingThread

public GrpcMessagingThread(Runnable target,
                           String name)

Constructs a new GrpcMessagingThread.

Parameters:

target - the target runnable

name - name of the thread

Method Detail

setContext

public void setContext(GrpcMessagingContext context)

Sets the Grpc messaging context.

Parameters:

context - context to set

getContext

public GrpcMessagingContext getContext()

Returns:

the Grpc messaging context or null if no context has been configured