|
Commons IO example source code file (FileAlterationMonitor.java)
This example Commons IO source code file (FileAlterationMonitor.java) is included in the DevDaily.com
"Java Source Code
Warehouse" project. The intent of this project is to help you "Learn Java by Example" TM.
The Commons IO FileAlterationMonitor.java source code
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.commons.io.monitor;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
/**
* A runnable that spawns a monitoring thread triggering any
* registered {@link FileAlterationObserver} at a specified interval.
*
* @see FileAlterationObserver
* @version $Id: FileAlterationMonitor.java 1022799 2010-10-15 00:56:13Z niallp $
* @since Commons IO 2.0
*/
public final class FileAlterationMonitor implements Runnable {
private final long interval;
private final List<FileAlterationObserver> observers = new CopyOnWriteArrayList();
private Thread thread = null;
private volatile boolean running = false;
/**
* Construct a monitor with a default interval of 10 seconds.
*/
public FileAlterationMonitor() {
this(10000);
}
/**
* Construct a monitor with the specified interval.
*
* @param interval The amount of time in miliseconds to wait between
* checks of the file system
*/
public FileAlterationMonitor(long interval) {
this.interval = interval;
}
/**
* Return the interval.
*
* @return the interval
*/
public long getInterval() {
return interval;
}
/**
* Construct a monitor with the specified interval and set of observers.
*
* @param interval The amount of time in miliseconds to wait between
* checks of the file system
* @param observers The set of observers to add to the monitor.
*/
public FileAlterationMonitor(long interval, FileAlterationObserver... observers) {
this(interval);
if (observers != null) {
for (FileAlterationObserver observer : observers) {
addObserver(observer);
}
}
}
/**
* Add a file system observer to this monitor.
*
* @param observer The file system observer to add
*/
public void addObserver(final FileAlterationObserver observer) {
if (observer != null) {
observers.add(observer);
}
}
/**
* Remove a file system observer from this monitor.
*
* @param observer The file system observer to remove
*/
public void removeObserver(final FileAlterationObserver observer) {
if (observer != null) {
while (observers.remove(observer)) {
}
}
}
/**
* Returns the set of {@link FileAlterationObserver} registered with
* this monitor.
*
* @return The set of {@link FileAlterationObserver}
*/
public Iterable<FileAlterationObserver> getObservers() {
return observers;
}
/**
* Start monitoring.
*
* @throws Exception if an error occurs initializing the observer
*/
public synchronized void start() throws Exception {
if (running) {
throw new IllegalStateException("Monitor is already running");
}
for (FileAlterationObserver observer : observers) {
observer.initialize();
}
running = true;
thread = new Thread(this);
thread.start();
}
/**
* Stop monitoring.
*
* @throws Exception if an error occurs initializing the observer
*/
public synchronized void stop() throws Exception {
if (running == false) {
throw new IllegalStateException("Monitor is not running");
}
running = false;
try {
thread.join(interval);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
for (FileAlterationObserver observer : observers) {
observer.destroy();
}
}
/**
* Run.
*/
public void run() {
while (running) {
for (FileAlterationObserver observer : observers) {
observer.checkAndNotify();
}
if (!running) {
break;
}
try {
Thread.sleep(interval);
} catch (final InterruptedException ignored) {
}
}
}
}
Other Commons IO examples (source code examples)
Here is a short list of links related to this Commons IO FileAlterationMonitor.java source code file:
|