【发布时间】：2011-02-18 13:51:39
【问题描述】：
多线程日志记录应用程序出现死锁情况。
小背景：
我的主应用程序有 4-6 个线程正在运行。负责监控我正在做的各种事情的健康状况、更新 GUI 等的主线程......然后我有一个发送线程和一个接收线程。发送和接收线程与物理硬件对话。我有时需要调试发送和接收线程看到的数据；即打印到控制台而不会由于数据的时间紧迫性而中断它们。顺便说一下，数据在 USB 总线上。
由于应用程序的线程性质，我想创建一个调试控制台，我可以从其他线程向它发送消息。调试控制台作为低优先级线程运行并实现环形缓冲区，这样当您打印到调试控制台时，消息会快速存储到环形缓冲区并设置和事件。调试控制台的线程从传入的绑定消息中获取 WaitingOnSingleObject 事件。当检测到事件时，控制台线程使用该消息更新 GUI 显示。简单吧？打印调用和控制台线程使用临界区来控制访问。
注意：如果我看到我正在丢弃消息，我可以调整环形缓冲区的大小（至少是这样）。
在一个测试应用程序中，如果我通过鼠标点击缓慢地调用它的 Print 方法，控制台工作得很好。我有一个按钮，我可以按下它来向控制台发送消息，它可以工作。但是，如果我加载任何类型的负载（多次调用 Print 方法），一切都会死锁。当我跟踪死锁时，我的 IDE 调试器跟踪到 EnterCriticalSection 并坐在那里。
注意：如果我删除 Lock/UnLock 调用并仅使用 Enter/LeaveCriticalSection（参见代码），我有时会工作，但仍会发现自己处于死锁状态。为了排除堆栈推送/弹出的死锁，我现在直接调用 Enter/LeaveCriticalSection 但这并没有解决我的问题....这里发生了什么？
这是一个 Print 语句，它允许我将一个简单的 int 传递给显示控制台。
void TGDB::Print(int I)
{
//Lock();
EnterCriticalSection(&CS);
if( !SuppressOutput )
{
//swprintf( MsgRec->Msg, L"%d", I);
sprintf( MsgRec->Msg, "%d", I);
MBuffer->PutMsg(MsgRec, 1);
}
SetEvent( m_hEvent );
LeaveCriticalSection(&CS);
//UnLock();
}
// My Lock/UnLock methods
void TGDB::Lock(void)
{
EnterCriticalSection(&CS);
}
bool TGDB::TryLock(void)
{
return( TryEnterCriticalSection(&CS) );
}
void TGDB::UnLock(void)
{
LeaveCriticalSection(&CS);
}
// This is how I implemented Console's thread routines
DWORD WINAPI TGDB::ConsoleThread(PVOID pA)
{
DWORD rVal;
TGDB *g = (TGDB *)pA;
return( g->ProcessMessages() );
}
DWORD TGDB::ProcessMessages()
{
DWORD rVal;
bool brVal;
int MsgCnt;
do
{
rVal = WaitForMultipleObjects(1, &m_hEvent, true, iWaitTime);
switch(rVal)
{
case WAIT_OBJECT_0:
EnterCriticalSection(&CS);
//Lock();
if( KeepRunning )
{
Info->Caption = "Rx";
Info->Refresh();
MsgCnt = MBuffer->GetMsgCount();
for(int i=0; i<MsgCnt; i++)
{
MBuffer->GetMsg( MsgRec, 1);
Log->Lines->Add(MsgRec->Msg);
}
}
brVal = KeepRunning;
ResetEvent( m_hEvent );
LeaveCriticalSection(&CS);
//UnLock();
break;
case WAIT_TIMEOUT:
EnterCriticalSection(&CS);
//Lock();
Info->Caption = "Idle";
Info->Refresh();
brVal = KeepRunning;
ResetEvent( m_hEvent );
LeaveCriticalSection(&CS);
//UnLock();
break;
case WAIT_FAILED:
EnterCriticalSection(&CS);
//Lock();
brVal = false;
Info->Caption = "ERROR";
Info->Refresh();
aLine.sprintf("Console error: [%d]", GetLastError() );
Log->Lines->Add(aLine);
aLine = "";
LeaveCriticalSection(&CS);
//UnLock();
break;
}
}while( brVal );
return( rVal );
}
MyTest1 和 MyTest2 只是我为响应按钮按下而调用的两个测试函数。无论我单击按钮多快，MyTest1 都不会引起问题。 MyTest2 几乎每次都死锁。
// No Dead Lock
void TTest::MyTest1()
{
if(gdb)
{
// else where: gdb = new TGDB;
gdb->Print(++I);
}
}
// Causes a Dead Lock
void TTest::MyTest2()
{
if(gdb)
{
// else where: gdb = new TGDB;
gdb->Print(++I);
gdb->Print(++I);
gdb->Print(++I);
gdb->Print(++I);
gdb->Print(++I);
gdb->Print(++I);
gdb->Print(++I);
gdb->Print(++I);
}
}
更新： 在我的环形缓冲区实现中发现了一个错误。在重负载下，当缓冲区包装时，我没有正确检测到完整的缓冲区，因此缓冲区没有返回。我很确定这个问题现在已经解决了。一旦我解决了环形缓冲区问题，性能就会好很多。但是，如果我减少 iWaitTime，我的死锁（或冻结问题）就会返回。
因此，经过更重负载的进一步测试后，看来我的死锁并没有消失。在超重负载下，我继续死锁，或者至少我的应用程序冻结了，但由于我修复了环形缓冲区问题，所以没有使用它。如果我将 MyTest2 中的 Print 调用次数增加一倍，我每次都可以轻松锁定......
另外，我更新的代码也反映在上面。我知道确保我的 Set & Reset 事件调用在临界区调用中。
【问题讨论】：
-
Offtopic：我想知道为什么代码没有突出显示？它在编辑视图中确实如此......无论如何，有时它确实如此。 =/
-
我的亮点...也许可以尝试清除浏览器缓存并重新启动？
-
你可以在调试器中运行它，对吧？ “死锁”时线程在哪里？
-
是的，我可以在调试器中运行它，也可以在我的主代码库中运行它，只要我没有遇到任何类型的负载；即在 for 循环内或连续调用 TDGB::Print 方法。请看我的两个测试函数（MyTest1 & MyTest2）。在调试器中，我到达 EnterCriticalSection 并挂起。
标签： c++ multithreading deadlock