asynDBCenter(修改)

浏览数：24 / 时间：2015年06月12日 
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(1) 
    {
        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 > 1000*10)//10访问一次
        {
            HeatBeat();//定时访问数据库
            m_lastCheckTime = GetTickCount();
        }
        else
        {
            boost::this_thread::interruptible_wait(1);
        }
    }
}

 

郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。

标签： class style 数据 log Go 方法 js si it class style 数据 log Go 方法 js si it

相关文章

随机文章

您可能还喜欢

您可能还喜欢