我正在编写一个应用程序,该应用程序将扫描目录中新添加的文件,然后使用WatchService对它们进行一些处理。此部分按预期工作。现在,我需要编写代码来处理在启动服务之前添加到目录中的文件。
天真的方法是在向监视服务注册路径之前简单地获取文件夹中的文件列表;不过,我担心这可能会在处理预先存在的文件和监视新事件之间留下差距,我可能会错过传入的文件。最安全的选择是开始监视事件,但不处理它们,直到我处理完已经存在的文件。
有没有办法手动将监视键的状态更改为"信号"?这将实现我的目标,但我在 WatchService 的文档中看不到执行此操作的方法。
天真的方法是简单地获取文件列表 文件夹,然后再将路径注册到监视服务;我有 但是,担心这可能会在处理 预先存在的文件并关注我可能会错过的新事件 传入文件。最安全的选择是开始监视 事件,但不处理它们,直到我已经处理了文件 目前。
以下是解决这些问题的一种方法:
同时启动watch-service
和get-files-list-from-folder-process
。
这两个进程都将文件(文件路径(放在线程安全的队列集合中 - 首先 - 这允许后进先出 (LIFO( 或先进先出 (FIFO( 处理。人们可以根据需要考虑java.util.concurrent.ConcurrentLinkedDeque
、LinkedBlockingDeque
、ConcurrentLinkedQueue
或LinkedBlockingQueue
。这样,所有文件都会一个接一个地处理 - 无论它是来自 get-files-list-from-folder-process 还是来自监视服务。
但是,需要进行检查以避免重复的文件处理,以确保没有文件两次添加到队列中。仅在应用程序开始时需要这样做。实际的文件处理程序本身可以跟踪另一个集合中处理的文件 - 可用于检查文件是否已处理。