SCADATrainSys/CCGDServer/ElectrictiyServerQt/TeachCMDReadThread.cpp

#include "TeachCMDReadThread.h"
#include <QDebug>
TeachCMDReadThread::TeachCMDReadThread(QObject *parent)
    : QThread(parent)
    , m_pSendQueue(NULL)
    , m_isCanRun(false)
{
}

TeachCMDReadThread::~TeachCMDReadThread()
{
}

void TeachCMDReadThread::run()
{
    while (!m_isCanRun)
    {
        //QThread::msleep(1);
        if (!QuequePOP())
        {
            QThread::msleep(5);
        }
    }
}

void TeachCMDReadThread::getCMD2List(OCCCOMMAND& pCMDData)
{
    if (m_pGetQueue)
    {
        m_pGetQueue->push(pCMDData);
    }
}

void TeachCMDReadThread::stopImmediately()
{
    m_isCanRun = true;
    //qDebug()<<QString::fromStdString(GBK2UTF8("TeachCMDRead¶ÓÁÐ״̬Ï̹߳رÕ"));
}

bool TeachCMDReadThread::QuequePOP()
{
    if (m_isCanRun)
    {
        return false;
    }
    if (m_pSendQueue == NULL)
    {
        return false;
    }
    OCCCOMMAND command;
    if (!m_pSendQueue->pop(command))
    {
        return false;
    } 
    emit signal_Command2Server(command.cmdType, command);
    return true;
}