提高多部分进程的互斥使用率

Boost mutex usage for multipart processes

本文关键字：使用率 进程 高多部      更新时间：2023-10-16

我有一个带有套接字通信类的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_;  
};

多个线程可能正在尝试发送消息，每个线程由三个或多个调用组成——设置头、内容，最后在途中发送消息。为了避免它们之间的冲突，我试图通过使用Mutex一次只保留一个作家。所需的行为是阻止第二个到达的写入程序，直到第一个到达的写程序解锁互斥锁。然后被阻止的写入程序将能够继续。

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

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

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

如有任何建议，我们将不胜感激。

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

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

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

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

相关文章：