0

假设我们有 std::map 套接字映射，它是一个多线程应用程序。将有多个线程访问映射中的套接字以发送套接字数据，同时只有一个线程访问映射中的套接字以接收数据，并且如果远程端关闭，该线程还将删除SocketInfo*。

在上述情况下，我们可以使用读写锁（pthread_rwlock_t）来同步线程吗？如果是，我们是否比 pthread_mutex_t 有更多的好处？

史蒂夫

[伪代码] 

     class CSocketIO {  
         std::map<int, SocketInfo*> m_Sockets; //socket value and socket info
         pthread_t  m_ReadingSocketThreads;   // for reading socket data
     };

     class CSession {
         void SendOutNetworkPackets(); //access sockets for sending sock data
         pthread_t m_WorkerThread;     // do jobs and send sock data
     };

     class CSomeClass {
         void SendOutNetworkPackets(); // also access sockets
         pthread_t m_WorkerThread;     // do jobs and send sock data
     };
4

2 回答 2

0

您不允许两个线程同时写入同一个套接字，对吗？您只想保护 a 的查找SocketInfo*不受map?

读写锁很少有益，而且往往有害。当我的客户端在多线程程序中存在非确定性错误时，我寻找的第一个罪魁祸首是不正确使用读写器锁。（您只能使用读卡器锁来保护真正的函数调用const。）

大概你的每个线程都在做这样的事情：

// do some work to figure out what to send
SocketInfo* my_socket_info = 0;

// critical section begins here
pthread_mutex_lock(the_map_mutex);
socket_map_t::const_iterator i = m_Sockets.find(id);
if (i != m_Sockets.end()) {
  my_socket_info = i->second;
}
pthread_mutex_unlock(the_map_mutex);
// critical section is done

if (my_socket_info != 0) {
  // do a bunch of work to actually send the data
  // (including acquiring a mutex specific to the socket unless
  // you have some other way of guaranteeing that the socket isn't
  // currently being written by some other thread)

您需要问的第二个问题（在“我真正保护的是什么const？”之后）是：the_map_mutex锁定的时间百分比是多少？如果它低于 50%，那么你就没有足够的争用来使读写器锁定获胜。the_map_mutex通过测量单个线程在临界区中花费的时间百分比，然后乘以系统上的硬件线程数，您可以快速估算受保护的临界区的利用率。

于 2013-06-04T18:27:00.117 回答
0

是的，您可以使用读/写锁来执行此操作，实际上建议这样做。

好处是您可以同时拥有多个具有读/写锁的读取器，而如果您使用简单的互斥锁，如果一个线程正在读取，其他想要读取的线程将阻塞，从而有效地序列化读取。使用读/写锁，读者只会在发生写入时阻塞。

于 2013-06-04T13:46:27.250 回答