正在等待WaitForMultipleObjects

我正在尝试为我的 FileWatcher 班级。

文件观察员 从线程类派生并使用 WaitForMultipleObjects 要在其线程过程中等待两个句柄,请执行以下操作:

1. 句柄从返回 FindFirstChangeNotification
2. 事件的句柄,它允许我取消上述等待。

所以基本上 文件观察员 正在等待最先发生的事情:文件更改或我告诉它停止监视。

现在,当尝试编写测试这个类的代码时,我需要等待它开始等待。

Peusdo Code:

FileWatcher.Wait(INFINITE)
ChangeFile()
// Verify that FileWatcher works (with some other event - unimportant...)

问题是有一个比赛条件。我需要首先确保filewatcher已经开始等待(即它的线程现在被阻塞在 WaitForMultipleObjects )在第2行触发文件更改之前。我不想使用sleeps,因为,嗯,它看起来很糟糕,在调试时一定会给我带来问题。

我很熟悉 SignalObjectAndWait 但它并不能真正解决我的问题,因为我需要它来“信号对象和等待多个对象”…

有什么想法吗?

编辑

为了澄清一点,这里是 文件观察员 班级:

// Inherit from this class, override OnChange, and call Start() to turn on monitoring. 
class FileChangeWatcher : public Utils::Thread
{
public:
    // File must exist before constructing this instance
    FileChangeWatcher(const std::string& filename);
virtual int Run();
    virtual void OnChange() = 0;
};

它继承自 Thread 并实现线程函数,它看起来像这样(非常简单):

_changeEvent = ::FindFirstChangeNotificationW(wfn.c_str(), FALSE, FILE_NOTIFY_CHANGE_LAST_WRITE);

HANDLE events[2] = { _changeEvent, m_hStopEvent };

DWORD hWaitDone = WAIT_OBJECT_0;
while (hWaitDone == WAIT_OBJECT_0)
{
    hWaitDone = ::WaitForMultipleObjects(2, events, FALSE, INFINITE);

    if (hWaitDone == WAIT_OBJECT_0)
        OnChange(); 
    else
        return Thread::THREAD_ABORTED;
} 
return THREAD_FINISHED;

注意,thread函数等待两个句柄,一个是更改通知,另一个是“stop thread”事件(从线程继承)。

现在测试此类的代码如下所示:

class TestFileWatcher : public FileChangeWatcher
{
public:
    bool Changed;
    Event evtDone;
    TestFileWatcher(const std::string& fname) : FileChangeWatcher(fname) { Changed = false; }
    virtual void OnChange()
    {
        Changed = true;
        evtDone.Set();
    }
};

并从CPP单元测试中调用:

std::string tempFile = TempFilePath();
StringToFile("Hello, file", tempFile);
TestFileWatcher tfw(tempFile);
tfw.Start();
::Sleep(100); // Ugly, but we have to wait for monitor to kick in in worker thread
StringToFile("Modify me", tempFile);
tfw.evtDone.Wait(INFINITE);
CPPUNIT_ASSERT(tfw.Changed);

我们的想法是摆脱中间的睡眠。