com.jn.langx.java8.util.io

类 PathWatcher

java.lang.Object

com.jn.langx.lifecycle.AbstractStatefulLifecycle

com.jn.langx.java8.util.io.PathWatcher

所有已实现的接口:

EventPublisherAware, Lifecycle, StatefulLifecycle, Runnable

public class PathWatcher
extends AbstractStatefulLifecycle
implements Runnable

Watch a Path (and sub directories) for Path changes.

Suitable replacement for the old Scanner implementation.

Allows for configured Excludes and Includes using FileSystem.getPathMatcher(String) syntax.

Reports activity via registered PathWatcher.Listeners

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	PathWatcher.Config
static class	PathWatcher.DirAction
static interface	PathWatcher.EventListListener EventListListener Listener that reports accumulated events in one shot
static interface	PathWatcher.Listener Listener for path change events
static class	PathWatcher.PathMatcherSet
class	PathWatcher.PathWatchEvent PathWatchEvent Represents a file event.
static class	PathWatcher.PathWatchEventType PathWatchEventType Type of an event

从类继承的嵌套类/接口 com.jn.langx.lifecycle.AbstractStatefulLifecycle

AbstractStatefulLifecycle.StopException

构造器概要

构造器

构造器和说明
PathWatcher() Construct new PathWatcher

方法概要

限定符和类型	方法和说明
void	addListener(EventListener listener) Add a listener for changes the watcher notices.
protected static <T> WatchEvent<T>	cast(WatchEvent<?> event)
protected void	doStart()
protected void	doStop()
Collection<PathWatcher.Config>	getConfigs()
Iterator<EventListener>	getListeners() Get an iterator over the listeners.
long	getUpdateQuietTimeMillis() Change the quiet time.
void	handleWatchEvent(Path path, PathWatcher.PathWatchEvent event) Add an event reported by the WatchService to list of pending events that will be sent after their quiet time has expired.
protected boolean	isNotifiable() Check to see if the watcher is in a state where it should generate watch events to the listeners.
boolean	isNotifyExistingOnStart()
protected void	register(Path path, PathWatcher.Config config)
boolean	removeListener(PathWatcher.Listener listener) Delete a listener
void	reset() Remove all current configs and listeners.
void	run() Forever loop.
void	setNotifyExistingOnStart(boolean notify) Whether or not to issue notifications for directories and files that already exist when the watcher starts.
void	setUpdateQuietTime(long duration, TimeUnit unit) Set the quiet time.
String	toString()
void	watch(Path file) Request watch on a the given path (either file or dir) using all Config defaults.
void	watch(PathWatcher.Config config) Request watch on a path with custom Config provided.

从类继承的方法 com.jn.langx.lifecycle.AbstractStatefulLifecycle

addEventListener, getEventPublisher, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeEventListener, setEventPublisher, shutdown, startup

从类继承的方法 java.lang.Object

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

构造器详细资料

PathWatcher

public PathWatcher()

Construct new PathWatcher

方法详细资料

cast

protected static <T> WatchEvent<T> cast(WatchEvent<?> event)

getConfigs

public Collection<PathWatcher.Config> getConfigs()

watch

public void watch(Path file)

Request watch on a the given path (either file or dir) using all Config defaults. In the case of a dir, the default is not to recurse into subdirs for watching.

参数:

file - the path to watch

watch

public void watch(PathWatcher.Config config)

Request watch on a path with custom Config provided.

参数:

config - the configuration to watch

addListener

public void addListener(EventListener listener)

Add a listener for changes the watcher notices.

参数:

listener - change listener

doStart

protected void doStart()
                throws Exception

覆盖:

doStart 在类中 AbstractStatefulLifecycle

抛出:

Exception

doStop

protected void doStop()
               throws Exception

覆盖:

doStop 在类中 AbstractStatefulLifecycle

抛出:

Exception

reset

public void reset()

Remove all current configs and listeners.

isNotifiable

protected boolean isNotifiable()

Check to see if the watcher is in a state where it should generate watch events to the listeners. Used to determine if watcher should generate events for existing files and dirs on startup.

返回:

true if the watcher should generate events to the listeners.

getListeners

public Iterator<EventListener> getListeners()

Get an iterator over the listeners.

返回:

iterator over the listeners.

getUpdateQuietTimeMillis

public long getUpdateQuietTimeMillis()

Change the quiet time.

返回:

the quiet time in millis

register

protected void register(Path path,
                        PathWatcher.Config config)
                 throws IOException

抛出:

IOException

removeListener

public boolean removeListener(PathWatcher.Listener listener)

Delete a listener

参数:

listener - the listener to remove

返回:

true if the listener existed and was removed

run

public void run()

Forever loop.

Wait for the WatchService to report some filesystem events for the watched paths.

When an event for a path first occurs, it is subjected to a quiet time. Subsequent events that arrive for the same path during this quiet time are accumulated and the timer reset. Only when the quiet time has expired are the accumulated events sent. MODIFY events are handled slightly differently - multiple MODIFY events arriving within a quiet time are coalesced into a single MODIFY event. Both the accumulation of events and coalescing of MODIFY events reduce the number and frequency of event reporting for "noisy" files (ie those that are undergoing rapid change).

指定者:

run 在接口中 Runnable

另请参阅:

Runnable.run()

handleWatchEvent

public void handleWatchEvent(Path path,
                             PathWatcher.PathWatchEvent event)

Add an event reported by the WatchService to list of pending events that will be sent after their quiet time has expired.

参数:

path - the path to add to the pending list

event - the pending event

setNotifyExistingOnStart

public void setNotifyExistingOnStart(boolean notify)

Whether or not to issue notifications for directories and files that already exist when the watcher starts.

参数:

notify - true if existing paths should be notified or not

isNotifyExistingOnStart

public boolean isNotifyExistingOnStart()

setUpdateQuietTime

public void setUpdateQuietTime(long duration,
                               TimeUnit unit)

Set the quiet time.

参数:

duration - the quiet time duration

unit - the quite time unit

toString

public String toString()

覆盖:

toString 在类中 AbstractStatefulLifecycle