c++ - 为现有异步代码创建 C++ 阻塞函数

Question

我有一个为专有软件编写的 C++ 插件，它可以异步调用名为 OpenLibrary 的函数。要知道库加载何时完成，我必须注册一个特定的事件。然后，当该事件被触发时，将调用 OnEvent 例程。由于专有原因，此逻辑在某种程度上已被 sanitizer ，但异步调用和 onEvent 触发器可以正常工作。不幸的是，由于 OpenLibrary 调用是异步的，因此循环不会被阻塞并继续进行而无需等待 EVENT_LIBRARY_LOADED 事件。我需要连续处理这些文件。

...

void MyApp::main() 
{
    for(int i=0; i<total; ++i) {
        pData->RegisterEvent( EVENT_LIBRARY_LOADED, this );   
        pData->OpenLibrary("c:/path/file.dat");  // asynchronous call
    }
}

...


void MyApp::OnEvent( ID eventType ) 
{
    if (eventType == EVENT_LIBRARY_LOADED) {
        qDebug() << "Library load has completed";
    }
}

...

该插件需要 VS2008 并且还利用了 Qt 库。

我想创建一个名为 waitForEvent 的函数，在该函数中后续代码将被阻塞，直到事件发生，然后 waitForEvent 可以将控制权返回给调用例程循环。这样，我就可以留在我的主例程循环中，并在继续之前等待事件发生。任何建议表示赞赏。

更新:我已经尝试了 Tas 下面的两个极好的建议，但在任何一种情况下，我都得到了相同的结果。 WaitForSingleObject 或 condition_variable.wait 均会阻止 EVENT_LIBRARY_LOADED 事件触发调用 OnEvent 函数，从而卡住循环。

如有更多建议，我们将不胜感激。

Answer 1

如果可以选择 boost 库，请使用 boost::condition_variable

您已经明确表示 C++11 不是一个选项(否则您可以使用 std::condition_variable)。 boost::condition_variable 将完成您需要做的事情，而且使用起来非常简单。你只需要调用wait和notify_one:

void MyApp::main() 
{
    for(int i=0; i<total; ++i) {
        pData->RegisterEvent( EVENT_LIBRARY_LOADED, this );   
        pData->OpenLibrary("c:/path/file.dat");  // asynchronous call
        condition_variable.wait(); // wait until we've been signaled
    }
}

void MyApp::OnEvent( ID eventType ) 
{
    if (eventType == EVENT_LIBRARY_LOADED) {
        qDebug() << "Library load has completed";
        // signal completion:
        condition_variable.notify_one();
    }
}

否则你可以使用Windows Event objects

它们的工作方式与上述非常相似，但使用起来稍微复杂一些(并且还特定于操作系统)。

HANDLE hEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL);
void MyApp::main() 
{
    for(int i=0; i<total; ++i) {
        // Prepare signal (otherwise if the signal has been Set already, Wait will return instantly)
        ::ResetEvent(hEvent);
        pData->RegisterEvent( EVENT_LIBRARY_LOADED, this );   
        pData->OpenLibrary("c:/path/file.dat");  // asynchronous call
        // wait for event to signal:
        ::WaitForSingleObject(hEvent, INFINITE);
    }
}
    
void MyApp::OnEvent( ID eventType ) 
{
    if (eventType == EVENT_LIBRARY_LOADED) {
        qDebug() << "Library load has completed";
        // Signal event:
        ::SetEvent(hEvent);
    }
}