如何阻止WatchService (java)

Question

我怎样才能阻止死刑的执行：

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()

但是这并没有给出任何结果，你能告诉我如何解决这个问题吗？

Answer 1

take()方法java.nio.WatchService被定义为不确定地等待，直到一个被监视的事件发生。所以没有办法“阻止”它。

如果您不想等待一个未确定的时间，可以使用poll() (它会立即返回)，或者使用poll(long timeout, TimeUnit unit) (在指定的时间之后或事件发生时返回)，不管首先发生什么。

运行这样一个观察器服务最“自然”的地方是一个后台线程，这样程序就可以在观察者等待寻找的事件时继续运行。Callable/Future类是这里使用的一个很好的候选。当观察者在Thread或Future中运行时，主程序可以使用Thread.interrupt()或Future.cancel()“停止”它。

并确保加入或守护您创建的线程，否则您的程序将无法完成。