asynDBCenter(修改)

asynDBCenter加入数据库心跳,其实是没有找到更好的方法,看看和以前有什么不同
mongo数据库重练,暂时没有找到好办法,只能这样定时访问
bool asynDBCenter::init(bool isInitRobot)
{
if(isInitRobot)
m_dbcenter->initRobot();
bool ret = m_dbcenter->initDBCenter();
m_lastCheckTime = GetTickCount();//记录了初始值
if(ret)
m_spThread.reset(new std::thread(std::bind(&asynDBCenter::threadLoop, this)));
return ret;
} //改成这种方式效率没有以前高了
/*
1.以前是通知的方式,然后有命令就立马唤醒线程
2.这种方式会导致线程不停的切换
*/ void asynDBCenter::threadLoop()
{
while()
{
CmdPkt pkt;
if(get_front_and_pop(pkt))//上了把cmd包的锁,保护包,获取请求cmd包
{
pkt.process(pkt.on_process, pkt.json.c_str());//根据cmd请求,访问数据库
continue;
}
if(GetTickCount() - m_lastCheckTime > *)//10访问一次
{
HeatBeat();//定时访问数据库
m_lastCheckTime = GetTickCount();
}
else
{
boost::this_thread::interruptible_wait();
}
}
}
上一篇:用c++写一个广告系统


下一篇:ZeroMQ接口函数之 :zmq_msg_more - 指出是不是还有更多的消息部分可以接收