这次使用的内存池是原公司的,利用hash_map做的,大概的接口是这样:
template <class CObject>
class ObjectPool
{ <br>public:<br> typedef hash_map<int64_t,ObjectBlock*> BlockMap;
virtual int pop(CObject *&ob);
virtual int push(const CObject *ob);<br>private:<br> BlockMap _block_map;
};
写测试代码比较了一下内存池和tcmalloc的差距!结果挺让人吃惊!
#define MAX_SIZE 50000
struct MsgToPut
{
UINT _wr_ptr;
UINT _rd_ptr;
UINT _length;
CHAR _base[1024];
void reset()
{
this->_rd_ptr = this->_wr_ptr = 0;
this->_length = 1024;
}
};
ObjectPool<MsgToPut> MsgPool;
void* newthread(void* argv)
{
long long int start = get_os_system_time();
for(int i=0;i<MAX_SIZE;i++)
{
MsgToPut* msg;
MsgPool.pop(msg);
if(msg == NULL)
{
printf("error\n");
}
}
long long int end = get_os_system_time();
printf("newthread ObjectPool:%d\n",end - start);
MsgToPut* mtp[MAX_SIZE];
for(int i=0;i<MAX_SIZE;i++)
{
mtp[i] = (MsgToPut*)tc_malloc(sizeof(MsgToPut));
mtp[i]->reset();
}
start = get_os_system_time();
printf("newthread tc malloc :%d\n",start - end);
return (void*)0;
}
int main()
{
pthread_t pid;
pthread_create(&pid,NULL,newthread,NULL);
pthread_create(&pid,NULL,newthread,NULL);
pthread_create(&pid,NULL,newthread,NULL);
long long int start = get_os_system_time();
for(int i=0;i<MAX_SIZE;i++)
{
MsgToPut* msg = NULL;
MsgPool.pop(msg);
if(msg == NULL)
{
printf("error\n");
}
}
long long int end = get_os_system_time();
printf("main ObjectPool:%d\n",end - start);
MsgToPut* mtp[MAX_SIZE];
for(int i=0;i<MAX_SIZE;i++)
{
mtp[i] = (MsgToPut*)tc_malloc(sizeof(MsgToPut));
mtp[i]->reset();
}
start = get_os_system_time();
printf("main tc malloc :%d\n",start - end);
return 0;
}
普遍打印数据为:
newthread ObjectPool:189
newthread ObjectPool:202
newthread tc malloc :24
newthread tc malloc :20
main ObjectPool:235
newthread ObjectPool:235
main tc malloc :21
newthread tc malloc :22