我正在尝试解决一例recursive_mutex。这是一段解释问题的代码。
void OnConnectionDisconnected()
{
boost::lock_guard<boost::mutex> lock ( m_mutexConnectionSet );
IPCSyncConnectionSharedPtrSet::iterator it = m_IPCSyncConnectionSet.find(spConnection);
if ( it != m_IPCSyncConnectionSet.end())
{
m_IPCSyncConnectionSet.erase(*it);
}
}
void ShutdownServer()
{
boost::lock_guard<boost::mutex> lock ( m_mutexConnectionSet );
IPCSyncConnectionSharedPtrSet::iterator it = m_IPCSyncConnectionSet.begin();
for (; it != m_IPCSyncConnectionSet.end(); )
{
if (*it)
{
IPCSyncConnectionSharedPtr spIPCConnection = (*it);
it++;
//This call indirectly calls OnConnectionDisconnected and erase the connection.
spIPCConnection->Disconnect();
}
else
{
++it;
}
}
}
当连接处于活动状态或断开连接时,在任何时候都可以在多个线程(n)上调用OnConnectionDisconnected,并且ShutdownServer只能在一个线程上调用。
ShutdownServer遍历所有连接,并在每个连接上调用Disconnect,这间接调用了OnConnectionDisconnected,而我实际上是在擦除连接。由于在其他线程中修改了连接集,因此在访问m_IPCSyncConnectionSet之前,我已经锁定了互斥锁。
我需要在上面的示例代码中使用recursive_mutex,因为在调用Shutdown时,互斥锁在同一线程上被锁定两次。
任何人都可以建议我如何解决上述问题并避免recursive_lock吗? recurive_mutex将根据本文http://www.fieryrobot.com/blog/2008/10/14/recursive-locks-will-kill-you/杀死您
谢谢,
最佳答案
在ShutdownServer()
中使用容器的临时副本。除了锁定问题之外,最好不要迭代由另一个函数修改的容器(即使这种特定的容器类型在擦除元素时不会使所有迭代器无效,这样的代码也将非常脆弱且不必要地复杂)。
void ShutdownServer()
{
boost::lock_guard<boost::mutex> lock ( m_mutexConnectionSet );
auto connections = m_IPCSyncConnectionSet;
lock.unlock();
for (auto it = connections.begin(); it != connections.end(); ++it)
if (*it)
(*it)->Disconnect();
}
现在,您既不必关心锁定,也不必关心迭代器的有效性。