ACE_Message_Block内存池

peakzhang

请问一下有没有基于ACE_Message_Block的内存池的实现代码。。每个Msg里面的ACE_Data_Block都是固定大小的。

peakzhang

需要改变Message_Block的分配器

peakzhang

搞定了。。把代码粘出来。希望对大家有用。。

2. #ifndef _ACE_MESSAGE_BLOCK_MANAGER
3. #define _ACE_MESSAGE_BLOCK_MANAGER
4. #include "Config.h"
5. class CMsgMgr
6. {
7. public:
8. CMsgMgr() {};
9. virtual ~CMsgMgr(){};
10. public:
11. void Init( int msgsize = 1024, int msgnum = 2048 );
12.     void Release();
14. ACE_Message_Block * AllocMsg( void );
16. private:
17.      ACE_Recursive_Thread_Mutex _lock;
18.   ACE_Allocator * msg_allocator_;
19.   ACE_Allocator * data_allocator_;
20.   ACE_Allocator * buff_allocator_;
21. };
22. ACE_Message_Block * CMsgMgr::AllocMsg( void )
23. {
24. ACE_Message_Block *msg;
25. ACE_NEW_MALLOC_RETURN( msg,
26.   static_cast<ACE_Message_Block*>( msg_allocator_->malloc(sizeof( ACE_Message_Block ) ) ),
27.   ACE_Message_Block( 1024,0,0,0,buff_allocator_,0,0,ACE_Time_Value::zero,ACE_Time_Value::max_time,data_allocator_,msg_allocator_ ),
28.   0
29.   );
30. msg->reset();
31. return msg;
32. }
34. void CMsgMgr::Init(int msgsize /* = 1024 */, int msgnum /* = 2048  */)
35. {
37. typedef char BUFFCOUNT[1024];
38. msg_allocator_=new ACE_Cached_Allocator<ACE_Message_Block,ACE_SYNCH_MUTEX>(msgnum);
39. data_allocator_ =new ACE_Cached_Allocator<ACE_Data_Block,ACE_SYNCH_MUTEX>(msgnum*2);
40.     buff_allocator_ = new ACE_Cached_Allocator<BUFFCOUNT,ACE_SYNCH_MUTEX>(msgnum*2);
43. }
45. void CMsgMgr::Release()
46. {
47.     delete msg_allocator_;
48. delete data_allocator_;
49. delete buff_allocator_;
50. }
52. typedef ACE_Singleton<CMsgMgr, ACE_Null_Mutex> MsgMgr;
53. #endif

复制代码

peakzhang

初始化

MsgMgr::instance()->Init();

用的时候只要这样子。

ACE_Message_Block* pMsg = MsgMgr::instance()->AllocMsg();

用完

pMsg->release();

结束

MsgMgr::instance()->release();