asynDBCenter(不断跟新)

bool asynDBCenter::get_front_and_pop(CmdPkt& pkt)
{
    if(m_queueCmdPkt.empty())
        return false;
    {
        std::unique_lock<std::mutex> lock(m_cmd_mtx);
        pkt = m_queueCmdPkt.front();
        m_queueCmdPkt.pop();
    }
    return true;
}
void asynDBCenter::push_cmd(CmdPkt pkt)
{
    {
        std::unique_lock<std::mutex> cond_lock(m_cond_mtx);//外层就是对应下面的wait操作，这样就实现了线程同步，当有数据时就通知，免得搞个循环判断
        {
            std::unique_lock<std::mutex> cmd_lock(m_cmd_mtx);
            m_queueCmdPkt.push(pkt);
        }
    }
    m_cond.notify_one();//通知threadLoop线程工作
}
void asynDBCenter::push_hr(HrPkt pkt)
{
    std::unique_lock<std::mutex> hr_lock(m_hr_mtx);
    m_queueHrPkt.push(pkt);
}

//------------------------------------------------------------------------------------------------------------------
void asynDBCenter::drive()
{

    HrPkt pkt;
    for (;;)
    {
        if(!m_queueHrPkt.size())
            break ;
        {
            std::unique_lock<std::mutex> hr_lock(m_hr_mtx);
            pkt = m_queueHrPkt.front();
            m_queueHrPkt.pop();
        }
        pkt.process(pkt.on_process, pkt.hr.c_str());                    
    }
}
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;
        }
        {//条件等待
            std::unique_lock<std::mutex> cond_lock(m_cond_mtx);
            m_cond.wait(cond_lock);//有通知时就解锁
        }

    }
}