7

溢出的文档指出：

OVERFLOW – 表示事件可能已丢失或丢弃。

它没有说在什么情况下我应该期望事件丢失或丢弃？起初我认为这将是非常快速地写入大量文件到文件夹的结果。我创建了几千个大小为零的文件，并将它们移动到受监控的目录中。没有溢出。

我错过了什么？

4

3 回答 3

7

产生溢出的最小示例

只需在之后watcherService.register和之前创建文件watcherService.take。

调用：

java Overflow 256

来控制事件的数量。

Java 7 和 Ubuntu 14.04 最多有 512 个事件。

每次发生溢出时，仅返回一个事件pollEvents()，但这在 Javadoc 上并没有明确规定。

考虑到这个限制如此之小，我觉得很奇怪：

编码：

import java.io.File;
import java.io.IOException;
import java.nio.file.FileSystems;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardWatchEventKinds;
import java.nio.file.WatchEvent;
import java.nio.file.WatchService;
import java.util.List;

public class Overflow {

    @SuppressWarnings("unchecked")
    static <T> WatchEvent<T> cast(WatchEvent<?> event) {
        return (WatchEvent<T>)event;
    }

    public static void main(final String[] args) throws InterruptedException, IOException {
        int nfiles;
        if (args.length > 0)
            nfiles = Integer.parseInt(args[0]);
        else
            nfiles = 10_000;
        Path directory = Files.createTempDirectory("watch-service-overflow");
        final WatchService watchService = FileSystems.getDefault().newWatchService();
        directory.register(
                watchService,
                StandardWatchEventKinds.ENTRY_CREATE,
                StandardWatchEventKinds.ENTRY_DELETE);
        final Path p = directory.resolve(Paths.get("Hello World!"));
        for (int i = 0; i < nfiles; i++) {
            Files.createFile(p);
            Files.delete(p);
        }
        List<WatchEvent<?>> events = watchService.take().pollEvents();
        for (final WatchEvent<?> event : events) {
            if (event.kind() == StandardWatchEventKinds.OVERFLOW) {
                System.out.println("Overflow.");
                System.out.println("Number of events: " + events.size());
                return;
            }
        }
        System.out.println("No overflow.");
        Files.delete(directory);
    }
}
于 2015-04-10T13:38:19.087 回答
6

我创建了几千个大小为零的文件，并将它们移动到受监控的目录中。没有溢出。

据推测，您在创建事件的同时使用这些事件。如果要触发溢出，请尝试暂停事件的消耗，生成大量事件（如上），然后恢复消耗。操作系统可以缓冲的未使用事件的数量肯定是有限制的。

于 2013-09-03T07:42:10.550 回答
6

“文件系统报告事件的速度可能比检索或处理它们的速度更快，并且实现可能会对它可能累积的事件数量施加未指定的限制。如果实现故意丢弃事件，那么它会安排键的 pollEvents 方法返回一个元素事件类型为 OVERFLOW。消费者可以使用此事件作为触发器来重新检查对象的状态。

从JavaDoc。

另请参阅 Steven C 的回答。我认为他关于未消费事件的观点有所不同。

于 2013-09-03T07:32:47.727 回答