#pragma once
#include "platform.h"
#include "BaseDefine.h"
#include <QObject>
#include <QThread>
class TeachCMDReadThread : public QThread
{
    Q_OBJECT

public:
    TeachCMDReadThread(QObject *parent);
    ~TeachCMDReadThread();
    void run();
    //设置队列
    void setNetQueue(CommandQueue* pSendQueue,CommandQueue* pGetQueue) 
    { 
        m_pSendQueue = pSendQueue;
        m_pGetQueue = pGetQueue;
    }
    //添加输入数据到队列
    void getCMD2List(OCCCOMMAND& pCMDData);
signals:
    //发送服务器数据:CmdType
    void signal_Command2Server(int MsgID, OCCCOMMAND pBUf);
public slots:
    void stopImmediately();
private:
    bool  QuequePOP();
    //向外发送的消息队列
    CommandQueue* m_pSendQueue;
    //内部接收解的消息队列
    CommandQueue* m_pGetQueue;
    //运行标志
    bool m_isCanRun;
};