java - 测试线程代码java

Question

我正在测试某个使用 WatchService 的类。此类有一个方法 processEvents，其工作原理如下(来自 http://docs.oracle.com/javase/tutorial/essential/io/notification.html ):

for (;;) {
    WatchKey key;
    try {
        key = watcher.take();
    } catch (InterruptedException x) {
        return;
    }
    for (WatchEvent<?> event: key.pollEvents()) {
        WatchEvent.Kind<?> kind = event.kind();
        // This key is registered only
        // for ENTRY_CREATE events,
        // but an OVERFLOW event can
        // occur regardless if events
        // are lost or discarded.
        if (kind == MODIFY) {
            //Do something
            AddToEvents(event);
        }
    }
    boolean valid = key.reset();
    if (!valid) {
        break;
    }
}

所以它有一个无限循环，需要在自己的线程中运行。现在我正在尝试测试“做某事”部分，但我不确定如何测试。例如，此测试方法不应失败:

@Test
public void testEventAdded() {
    Thread thread = new Thread() {
        @Override
        public void run() {
            synchronized(currentThread) {
                MyClass.processEvents();
            }
        }
    };
    thread.start();
    File tempFile = File.createTempFile("temporary file", null, Paths.get(testdirectory).toFile());
    tempFile.deleteOnExit();
    assertFalse(MyClass.getEvents().isEmpty());
}

编辑:澄清一下，getEvents 不应该为空(因为已经创建了一个文件)，这甚至可以被 watchservice 检测到(打印完成)。但由于它在不同的线程中运行，测试将其报告为空，因此失败，因为 isEmpty 在assertFalse 中不应该为 true。

Answer 1

    File tempFile = File.createTempFile("temporary file", null, Paths.get(testdirectory).toFile());
    tempFile.deleteOnExit();
    Thread.sleep(5000);
    assertFalse(MyClass.getEvents().isEmpty());

我想 5 秒应该足够长了？

此外，您可能需要使 getEvents 同步或进行其他操作。