Class WatcherCleaner
java.lang.Object
java.lang.Thread
org.apache.zookeeper.server.watch.WatcherCleaner
- All Implemented Interfaces:
Runnable
Thread used to lazily clean up the closed watcher, it will trigger the
clean up when the dead watchers get certain number or some number of
seconds has elapsed since last clean up.
Cost of running it:
- need to go through all the paths even if the watcher may only
watching a single path
- block in the path BitHashSet when we try to check the dead watcher
which won't block other stuff
-
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
ConstructorsConstructorDescriptionWatcherCleaner
(IDeadWatcherListener listener) WatcherCleaner
(IDeadWatcherListener listener, int watcherCleanThreshold, int watcherCleanIntervalInSeconds, int watcherCleanThreadsNum, int maxInProcessingDeadWatchers) -
Method Summary
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
Constructor Details
-
WatcherCleaner
-
WatcherCleaner
public WatcherCleaner(IDeadWatcherListener listener, int watcherCleanThreshold, int watcherCleanIntervalInSeconds, int watcherCleanThreadsNum, int maxInProcessingDeadWatchers)
-
-
Method Details