我怎样才能停止 WatchService (java)

如何解决我怎样才能停止 WatchService (java)

如何停止执行：

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()“停止”它。

并且一定要加入或守护你创建的线程，否则你的程序将无法完成。