问题描述
如何停止执行:
key = watchService.take()
我的代码:
//Watcher
public class DirectoryWatcherExample {
public static void main(String[] args) throws IOException,InterruptedException {
WatchService watchService = FileSystems.getDefault().newWatchService();
//My folder
Path path = Paths.get("D:\\java\\Input");
path.register(watchService,StandardWatchEventKinds.ENTRY_CREATE);
WatchKey key;
while (((key = watchService.take()) != null)) {
System.out.println(key);
System.out.println(key.toString());
for (WatchEvent<?> event : key.pollEvents()) {
if(event.context().toString().contains(".dat")){
System.out.println("FileName: "+event.context());
}
}
key.reset();
}
watchService.close();
}
}
我的代码正在等待该行的执行,是否有可能以某种方式停止执行,尝试过:
key.cancel();
watchService.close()
但这并没有给出任何结果,你能告诉我如何解决这个问题吗?
解决方法
take()
的 java.nio.WatchService
方法定义以不确定地等待,直到发生被监视的事件。所以没有办法“阻止”它。
如果您不想等待不确定的时间,您可以使用 poll()
,它立即返回,或者 poll(long timeout,TimeUnit unit)
在指定时间或事件发生后返回,无论先发生什么。
运行这种观察者服务最“自然”的地方是后台线程,这样程序就可以在观察者等待寻找的事件时继续进行。 Callable
/Future
类非常适合在这里使用。当观察者在 Thread
或 Future
中运行时,主程序可以使用 Thread.interrupt()
或 Future.cancel()
“停止”它。
并且一定要加入或守护你创建的线程,否则你的程序将无法完成。