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 套接字进行的——主要的应用程序只与助手对话；帮助者通过网络与其他帮助者交谈。

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

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

尽管如此，在使用（编号）消息调用 EnqueueMessageForUIThread() 函数和弹出 PopupMessageForNonUIThread() 函数之间的某个位置，如果我从 lock.Unlock() 中删除 cmets 和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;
}

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