c++ - winapi 为什么/如何反转消息的顺序？

Question

考虑以下代码:

CCritialSection listLock;
std::list<CString> messageList;
extern MyApp theApp;    // public inheritance from CWinApp
const int aMessageNumber = WM_APP + 123;

void MyApp::EnqueueMessageForUIThread( const CString message )
{
    CSingleLock lock( &listLock, TRUE );
    messageList.push_back( message );
    theApp.m_pMainWnd->PostMessage( aMessageNumber  );
}

void MyApp:PopupMessageFromNonUIThread( void)
{
    // This function is called via ON_MESSAGE( aMessageNumber, ... )
    CSingleLock lock( &listLock, TRUE );
    bool messagesAvailable( !messageList.empty() );
    while ( messagesAvailable )
    {
        const CString message( messageList.front() );
        messageList.pop_front();
//      lock.Unlock();
        AfxMessageBox( message, MB_ICONINFORMATION );
//      lock.Lock();
        messagesAvailable = !messageList.empty();
    }
}

正如这两个函数名称所暗示的那样，这些函数旨在在 UI 线程中弹出来自非 UI 线程的消息 - 当从非 UI 线程调用 UI 函数时，在 Windows 上会发生不好的事情。

如果 lock.Unlock() 和 lock.Lock() 这两行不被注释掉肯定会更好。这将允许在每个弹出消息等待用户响应时将更多消息排队 - 非 UI 线程将不必阻塞并等待 listLock 可用。

但是...至少在我使用这些函数的上下文中，我一直按顺序排列三个消息，然后以相反的顺序将它们弹出给用户。这怎么可能？

万一它很重要(我不相信它很重要)，这些功能是“主应用程序”代码的一部分，它与 Windows PC 上的“帮助应用程序”一起运行。还有另一台(相同的)PC 运行相同的两个应用程序。各方之间的通信是通过 Windows 套接字进行的——主要的应用程序只与助手对话；帮助者通过网络与其他帮助者交谈。

我始终按照上述代码顺序看到的三个消息，但当我取消注释两个锁定/解锁行时顺序相反，是“环回”测试的一部分 - 我从一个主应用程序向另一个主应用程序发送消息，让第一个(本地)助手确认它，然后让第二个(远程)助手确认它，然后让第二个(远程)主应用程序确认它。

在网络上捕获数据包可确认数据包是按预期顺序发送/接收的。在消息到达时对其进行编号可确认它们已按顺序接收。只有一个接收线程，不可能在完成之前多次重新进入 EnqueueMessageForUIThread() 函数。

尽管如此，在使用(编号)消息调用 EnqueueMessageForUIThread() 函数和让 PopupMessageForNonUIThread() 函数弹出它之间的某个时间点，这些消息将被弹出如果我从 lock.Unlock() 和 lock.Lock() 中删除注释，则反向向上。

如何？

Answer 1

PostMessage 是线程安全的，它设计用于将消息转发到其他线程。这意味着您遇到的线程不安全问题存在于您的代码中。

在本例中，您打开了一个消息框。消息框本身运行消息循环，因此，如果您在 PopupMessageFromNonUIThread 中设置断点，您会发现在第一个消息框执行任何操作之前，您正在从队列中拉出第二条和第三条消息。

您需要为此实现自己的模式，它不需要为消息泵锁定，只需要为传输队列锁定。

bool MyApp::getNextMessage(CString& into)
{
    CSingleLock lock( &listLock, TRUE );
    if ( messageList.empty() )
        return false;
    into = messageList.front();
    messageList.pop_front();
    return true;
}

void MyApp:PopupMessageFromNonUIThread( void)
{
    static bool displaying = false;
    if (displaying)
        return;

    displaying = true;

    // This function is called via ON_MESSAGE( aMessageNumber, ... )
    CString message;
    while ( getNextMessage(message) )
    {
        AfxMessageBox( message, MB_ICONINFORMATION );
    }

    displaying = false;
}

哦，我知道这不是最有效的互斥策略......但你正在显示一个消息框 - 优化你在它周围使用的锁定策略并不重要。