异步方法中的 Spring Boot while 循环停止应用程序

Question

我正在尝试创建一个观察者来查找对特定文件夹的更改。我创建了一个观察者并将它放在一个异步方法中，但是当我从服务中调用它时，应用程序由于观察者方法中的 while 循环而暂停。就像该方法没有在新线程中执行一样。这是包含我要执行的方法的类；    @Servicepublic class FileWatcher {    @Async    public Future<Object> watch(Path path, DataParser parser) throws IOException, InterruptedException {        WatchService watchService = FileSystems.getDefault().newWatchService();        path.register(                watchService,                StandardWatchEventKinds.ENTRY_CREATE,                StandardWatchEventKinds.ENTRY_DELETE,                StandardWatchEventKinds.ENTRY_MODIFY);        WatchKey key;        while ((key = watchService.take()) != null) {            for (WatchEvent<?> event : key.pollEvents()) {                File file = new File(path.toString() + "/" + event.context());                if (event.kind() == StandardWatchEventKinds.ENTRY_MODIFY) {                    parser.fileChanged(file);                }                if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {                    parser.fileCreated(file);                }                if (event.kind() == StandardWatchEventKinds.ENTRY_DELETE) {                    parser.fileRemoved(file);                }            }            key.reset();        }        return null;    }}然后，我在服务的构造函数中调用它。@Servicepublic class SPIService {    private final String DATAFOLDER = "/spi";    private Path dataPath;    public SPIService(@Value("${com.zf.trw.visualisation.data.path}") String dataPath) {        this.dataPath = Paths.get(dataPath + DATAFOLDER);        FileWatcher fileWatcher = new FileWatcher();        try {            fileWatcher.watch(this.dataPath, new SPIParser());        } catch (Exception e) {            e.printStackTrace();        }    }}为什么这不起作用？是因为我从服务的构造函数中调用方法吗？

Answer 1

您正在使用new FileWatcher()这意味着该实例不是托管 bean。这也意味着@Async被忽略（这解释了您的应用程序停止）。你需要@Autowire FileWatcher改为。

另请注意，您的解决方案对我来说似乎非常可疑，不仅因为有无限循环，而且在@Async方法中有一个（这有一些重要的后果）。我至少会为它使用一个单线程线程池。