Package org.apache.hadoop.hbase.io

Class FileChangeWatcher.WatcherThread

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.io.FileChangeWatcher.WatcherThread

All Implemented Interfaces:

Runnable

Enclosing class:

FileChangeWatcher

private class FileChangeWatcher.WatcherThread
extends Thread

Inner class that implements the watcher thread logic.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Consumer<WatchEvent<?>>	callback
private static final String	THREAD_NAME_PREFIX
(package private) final WatchService	watchService

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
WatcherThread(String threadNameSuffix, WatchService watchService, Consumer<WatchEvent<?>> callback)

Method Summary

Modifier and Type	Method	Description
void	run()
private void	runLoop()

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

Field Details

THREAD_NAME_PREFIX

private static final String THREAD_NAME_PREFIX

See Also:

• Constant Field Values

watchService

final WatchService watchService

callback

final Consumer<WatchEvent<?>> callback

Constructor Details

WatcherThread

WatcherThread(String threadNameSuffix,
 WatchService watchService,
 Consumer<WatchEvent<?>> callback)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

runLoop

private void runLoop()