#include "XDecodeThread.h"

XDecodeThread::XDecodeThread()
{
    if(m_pxDecode == nullptr)
    {
        m_pxDecode = new XDecode();
    }
}

XDecodeThread::~XDecodeThread()
{
    //等待线程结束
    m_blIsExit = true;
    wait();
}

void XDecodeThread::Close()
{
    Clear();
    //等待线程结束
    m_blIsExit = true;
    wait();
    m_qmtxDecodeThread.lock();
    if(m_pxDecode != nullptr)
    {
        m_pxDecode->Close();
        delete m_pxDecode;
        m_pxDecode = nullptr;
    }
    m_qmtxDecodeThread.unlock();
}

void XDecodeThread::Clear()
{
    m_qmtxDecodeThread.lock();
    if(m_pxDecode != nullptr)
    {
        m_pxDecode->Clear();
    }
    while(!m_qlstAvPacket.isEmpty())
    {
        AVPacket *avPacket = m_qlstAvPacket.front();
        if(avPacket)
        {
            av_packet_free(&avPacket);
        }
        m_qlstAvPacket.pop_front();
    }
    m_qmtxDecodeThread.unlock();
    return;
}

void XDecodeThread::Push(AVPacket *_pqAVPacket)
{
    if(_pqAVPacket == nullptr)
    {
        qDebug()<<"_pqAVPacket == nullptr";
        return;
    }

    while(!m_blIsExit)
    {
        m_qmtxDecodeThread.lock();
        if(m_qlstAvPacket.size() < LIST_AVPACKET_MAX_COUNT)
        {
            m_qlstAvPacket.push_back(_pqAVPacket);
            m_qmtxDecodeThread.unlock();
            break;
        }
        m_qmtxDecodeThread.unlock();
        QThread::msleep(1);
    }
}

AVPacket *XDecodeThread::Pop()
{
    if(m_qlstAvPacket.isEmpty())
    {
        //qDebug()<<"m_qlstAvPacket.isEmpty";
        return nullptr;
    }

    AVPacket *avPacket;
    m_qmtxDecodeThread.lock();
    avPacket = m_qlstAvPacket.front();
    m_qlstAvPacket.pop_front();
    m_qmtxDecodeThread.unlock();
    return avPacket;
}