Why/how winapi 会颠倒消息的顺序吗?
Why/how does winapi reverse the order of messages?
考虑以下代码:
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 线程的消息 - 当 Windows 上发生错误时UI 函数是从非 UI 线程调用的。
lock.Unlock()
和lock.Lock()
这两行不注释掉肯定更好。这将允许在每个弹出消息等待用户响应时将更多消息排队 - 非 UI 线程将不必阻塞并等待 listLock
可用。
但是...至少在我使用这些函数的上下文中,我一直按顺序排列三个消息,然后以相反的顺序将它们弹出给用户。这怎么可能?
万一它很重要(我不相信它很重要),这些函数是 "main app" 代码的一部分,它与 [=43] 上的 "helper app" 一起运行=] 电脑。还有另一台(相同的)PC 运行 同样的两个应用程序。各方之间的通信是通过 Windows 套接字 - 主要应用程序只与助手对话;帮助者通过网络与其他帮助者交谈。
我一直按上述代码顺序看到的三条消息,但当我取消注释两行 Lock/Unlock 时顺序相反,是 "loopback" 测试的一部分 - 我从一个主应用程序到另一个主应用程序,让第一个(本地)助手确认它,然后让第二个(远程)助手确认它,然后让第二个(远程)主应用程序确认它。
在网络上捕获数据包可确认数据包 sent/received 符合预期顺序。在消息到达时对其进行编号可确认它们已按顺序接收。只有一个接收线程,无法在完成前多次重新进入EnqueueMessageForUIThread()
函数。
尽管如此,在使用(编号)消息调用 EnqueueMessageForUIThread()
函数和让 PopupMessageForNonUIThread()
函数弹出它之间的某处,如果我删除评论,这些消息将反向弹出来自 lock.Unlock()
和 lock.Lock()
.
如何?
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;
}
哦,我知道这不是最有效的互斥策略...但是您正在显示一个消息框 - 优化您在它周围使用的锁定策略并不重要。
考虑以下代码:
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 线程的消息 - 当 Windows 上发生错误时UI 函数是从非 UI 线程调用的。
lock.Unlock()
和lock.Lock()
这两行不注释掉肯定更好。这将允许在每个弹出消息等待用户响应时将更多消息排队 - 非 UI 线程将不必阻塞并等待 listLock
可用。
但是...至少在我使用这些函数的上下文中,我一直按顺序排列三个消息,然后以相反的顺序将它们弹出给用户。这怎么可能?
万一它很重要(我不相信它很重要),这些函数是 "main app" 代码的一部分,它与 [=43] 上的 "helper app" 一起运行=] 电脑。还有另一台(相同的)PC 运行 同样的两个应用程序。各方之间的通信是通过 Windows 套接字 - 主要应用程序只与助手对话;帮助者通过网络与其他帮助者交谈。
我一直按上述代码顺序看到的三条消息,但当我取消注释两行 Lock/Unlock 时顺序相反,是 "loopback" 测试的一部分 - 我从一个主应用程序到另一个主应用程序,让第一个(本地)助手确认它,然后让第二个(远程)助手确认它,然后让第二个(远程)主应用程序确认它。
在网络上捕获数据包可确认数据包 sent/received 符合预期顺序。在消息到达时对其进行编号可确认它们已按顺序接收。只有一个接收线程,无法在完成前多次重新进入EnqueueMessageForUIThread()
函数。
尽管如此,在使用(编号)消息调用 EnqueueMessageForUIThread()
函数和让 PopupMessageForNonUIThread()
函数弹出它之间的某处,如果我删除评论,这些消息将反向弹出来自 lock.Unlock()
和 lock.Lock()
.
如何?
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;
}
哦,我知道这不是最有效的互斥策略...但是您正在显示一个消息框 - 优化您在它周围使用的锁定策略并不重要。