1

我有一个带有套接字通信类的 c++ 程序。每个套接字都有一个用于组装输出消息的大型专用缓冲区，因此用法如下：

class CSocketClass {
public:
    SetMsgHeader(int n) { Mutex_.lock(); DoWhateverIsNeededToSetHeaderInBuffer(n); } // where n would be the message type
    SetMsgField(double a); { DoWhateverIsNeededToSetDataInBuffer(a); } // where a would be some arbitrary content
    SendMsg(); { DoWhateverIsNeededToSendBuffer(); Mutex_.unlock(); } // where this would send the number of bytes added to the buffer since the   header was set
private:
    char buffer[reallylarge];
    MiscSocketApparatus... 
    boost::mutex   Mutex_;  
};

多个线程可能正在尝试发送消息，每个线程由三个或更多调用组成，设置标题、内容，并最终在途中发送消息。为了避免它们发生冲突，我尝试使用互斥锁一次只保留一个作家。期望的行为是阻止第二个到达的写入器，直到第一个到达的写入器解锁互斥锁。然后被阻止的作家将能够继续。

这似乎在大多数情况下都有效，但在极少数情况下（不是每天），死锁似乎仍然会发生。

我更熟悉使用范围锁的更简单的锁问题，但这些概念可能无法完美地转化为这个问题，其中锁需要在对拥有锁的对象的多次调用中保持不变。

通过阅读 Boost 同步教程，我认为有更好的方法可以做到这一点，但不清楚什么是最好的。

任何建议将不胜感激。

4

1 回答 1

0

由于每个线程都有自己的缓冲区，因此每个线程都在自己的缓冲区中构建完整的消息，然后锁定互斥体并发送消息。

更好的是，有一个线程来实际发送消息，并且有 N 个线程来创建它们。在两者之间放置一个线程安全队列，因此线程创建一条消息，将其放入队列中，然后（如果需要）返回创建另一条消息。消息发送者只是不断地等待队列中的消息，检索它，发送它，然后重复。

您可能还需要一个线程安全的缓冲区集合，因此当发送消息时，发送线程可以将缓冲区放置在消息构建器线程可以在需要时再次使用它的位置。

顺便说一句：对于缓冲区，我将使用 anstd::string或 a std::vector，而不是原始数组。

于 2013-09-05T03:01:12.533 回答