一个消息队列的问题

peakzhang

下面是我封装的一个消息队列类，不知道这样会不会内存泄露，大家帮忙看看

1. class MessageQueue
2. {
3. public:
4. MessageQueue(const int nMessageLength)
5. {
6.   m_pMessageBlock = new ACE_Message_Block(nMessageLength);
7.   m_nMessageLength = nMessageLength;
8.   m_clMessageQueue.high_water_mark (nMessageLength*1000);
9.   m_clMessageQueue.low_water_mark (nMessageLength*1000);
10. }
11. ~MessageQueue(){delete m_pMessageBlock;}
12. bool Send(char* buffer);
13. bool Receive(char* buffer);
14. private:
15. int m_nMessageLength;
16. ACE_Message_Queue<ACE_MT_SYNCH> m_clMessageQueue;
17. ACE_Message_Block* m_pMessageBlock;
18. };
19. //
20. //发送
21. //
22. bool MessageQueue::Send(char* buffer)
23. {
24. if(NULL == buffer)return false;
25. ACE_Time_Value initial (0);
26. memcpy(m_pMessageBlock->wr_ptr(),buffer,m_nMessageLength);
27. if(m_clMessageQueue.enqueue(m_pMessageBlock,&initial) == -1)return false;
28. return true;
29. }
30. //
31. //接收
32. //
33. bool MessageQueue::Receive(char* buffer)
34. {
35. if(NULL == buffer)return false;
36. ACE_Time_Value initial (0);
37. if(m_clMessageQueue.dequeue(m_pMessageBlock,&initial) == -1)return false;
38. memcpy(buffer,m_pMessageBlock->rd_ptr(),m_nMessageLength);
40. return true;
41. }

复制代码

peakzhang

建议直接使用ACE_Task，这样用不太好。是否有泄漏，还得看你完整代码的管理。
一般说来，从队列出来的ACE_Message_Block,使用完成后，要调用release()清除。可是你的代码是保存起来了。