WatchService听起来像是一个令人兴奋的想法...不幸的是,它似乎与教程/ api中的警告一样低,并不真正适合Swing事件模型(或者我错过了一些明显的,非零概率
拿代码 来自教程中的WatchDir示例 (简单地说只处理一个目录),我基本上结束了
- 扩展SwingWorker
- 在构造函数中执行注册工作
- 把无限循环放在doInBackground中等待一个键
- 通过key.pollEvents()检索时发布每个WatchEvent
通过使用已删除/创建的文件作为newValue触发propertyChangeEvents来处理块
@SuppressWarnings("unchecked") public class FileWorker extends SwingWorker<Void, WatchEvent<Path>> { public static final String DELETED = "deletedFile"; public static final String CREATED = "createdFile"; private Path directory; private WatchService watcher; public FileWorker(File file) throws IOException { directory = file.toPath(); watcher = FileSystems.getDefault().newWatchService(); directory.register(watcher, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY); } @Override protected Void doInBackground() throws Exception { for (;;) { // wait for key to be signalled WatchKey key; try { key = watcher.take(); } catch (InterruptedException x) { return null; } for (WatchEvent<?> event : key.pollEvents()) { WatchEvent.Kind<?> kind = event.kind(); // TBD - provide example of how OVERFLOW event is handled if (kind == OVERFLOW) { continue; } publish((WatchEvent<Path>) event); } // reset key return if directory no longer accessible boolean valid = key.reset(); if (!valid) { break; } } return null; } @Override protected void process(List<WatchEvent<Path>> chunks) { super.process(chunks); for (WatchEvent<Path> event : chunks) { WatchEvent.Kind<?> kind = event.kind(); Path name = event.context(); Path child = directory.resolve(name); File file = child.toFile(); if (StandardWatchEventKinds.ENTRY_DELETE == kind) { firePropertyChange(DELETED, null, file); } else if (StandardWatchEventKinds.ENTRY_CREATE == kind) { firePropertyChange(CREATED, null, file); } } } }
基本的想法是使用代码幸福地不知道粘糊糊的细节:它听取属性的变化和f.i.根据需要更新任意模型:
String testDir = "D:\\scans\\library";
File directory = new File(testDir);
final DefaultListModel<File> model = new DefaultListModel<File>();
for (File file : directory.listFiles()) {
model.addElement(file);
}
final FileWorker worker = new FileWorker(directory);
PropertyChangeListener l = new PropertyChangeListener() {
@Override
public void propertyChange(PropertyChangeEvent evt) {
if (FileWorker.DELETED == evt.getPropertyName()) {
model.removeElement(evt.getNewValue());
} else if (FileWorker.CREATED == evt.getPropertyName()) {
model.addElement((File) evt.getNewValue());
}
}
};
worker.addPropertyChangeListener(l);
JXList list = new JXList(model);
似乎工作,但我感到不舒服
- 我自己作为线程不可知论自己:我到目前为止看到的所有示例片段都通过使用watcher.take()来阻止等待线程。他们为什么这样做?期望至少有一些人使用watcher.poll()并稍微睡一觉。
- SwingWorker发布方法似乎不太合适:现在它没关系,因为我只看一个目录(不想太过于错误的方向:)当试图观看几个目录时(如原始WatchDir示例)有几个键和WatchEvent相对于其中之一。要解决这条路,我需要事件和 目录 [A]关键是观看 - 但只能传递一个。但是,最有可能错误地分配逻辑
[一个] 编辑 (由@ trashgods的评论引发) - 它实际上不是我必须随事件传递的密钥,它是报告更改的目录。相应地改变了问题
仅供参考,这个问题是交叉发布的 OTN摇摆论坛
附录
阅读WatchKey的api文档:
有几个线程从手表中检索信号键 服务然后应该注意确保重置方法 仅在处理了对象的事件后调用。
似乎暗示事件应该
- 在检索WatchKey的同一线程上处理
- 重置密钥后不应触摸
不完全确定,但结合(未来)要求递归观看目录(不止一个)决定遵循@Eels建议,有点 - 将很快发布我定居的代码
编辑 刚刚接受了我自己的答案 - 如果有人有合理的反对意见,我会谦卑地回复