Player practice 20 unpacking thread

To open xvideothread（ To initialize the playback control, its abstract class needs to be passed in ）,xaudiothread,xedmux,
take testtread Class encapsulated into the unpacking thread

1.xdemuxthread.h

#pragma once
#include<qthread.h>
#include<mutex>
#include"ivideocall.h"
#include"xdemux.h"
#include"xaudiothread.h"
#include"xvideothread.h"
class xdemuxthread:public QThread
{
    
public:
	virtual bool open(const char* url,ivideocall *call);
	// Start all threads , Create an object and open 
	virtual void start();
	xdemuxthread();
	virtual ~xdemuxthread();
	void run();
protected:
	xdemux *demux=0;
	xvideothread *vt=0;
	xaudiothread *at=0;
	std::mutex mux;
	bool isexit = false;
};

#include "xdemuxthread.h"
#include<iostream>
using namespace std;
void xdemuxthread::run()
{
    
	while (!isexit)
	{
    
		mux.lock();
		if (!demux)
		{
    
			mux.unlock();// if demux If it is not opened, unlock it to let other threads in , wait for 5 Second hope demux Can open the , Then make the next judgment , Judge demux Whether to open 
			msleep(5);
			continue;
		}
		AVPacket* pkt = demux->readfz();
        if (!pkt)
		{
    
			// It's the end 
			mux.unlock();
			msleep(5);
			continue;
		}
		if (demux->isvideo(pkt))
		{
    
			if (vt)vt->push(pkt);
		}
		else
		{
    
			if (at)at->push(pkt);
		}
		mux.unlock();
	}
}
xdemuxthread::xdemuxthread()
{
    

}
xdemuxthread::~xdemuxthread()
{
    
	isexit = true;// The current thread is not stopped until the destructor is called 
	wait();
	cout << " Unpack thread exit " << endl;
}
bool xdemuxthread::open(const char* url, ivideocall* call)
{
    
	mux.lock();
	if (!demux)demux = new xdemux();
	if (!vt)vt = new xvideothread();
	if (!at)at = new xaudiothread();
	
	bool re=demux->Open(url);
	if (!re)
	{
    
		cout << "demux->open(url) failed!";
		return false;
	}
	re = vt->open(demux->CopyVPara(),call,demux->width,demux->height);
	if (!re)
	{
    
		cout << "vt->open(url) failed!";
		re = false;
	}
	re = at->open(demux->CopyAPara(), demux->sampletrate, demux->channels);
	if (!re)
	{
    
		cout << "at->open(url) failed!";
		re = false;
	}
	mux.unlock();
	cout << "xdemuxopen open:(1 success 0 Failure )" << re << endl;
	return true;
}
void xdemuxthread::start()
{
    
	mux.lock();
	QThread::start();// Start the current thread , Call the... Of the current class run()
	
	if (at)at->start();
	if (vt)vt->start();
	mux.unlock();
}

1. stay open Open audio thread and video thread in
2. When the main function calls the... Of the decoding thread run Called when xdemuxthread::start(), Call the... Of the audio thread in this function run With video threads run
3. stay run By reading the package packet, Determine its type , If it's a video push Queue for video threads , If it is audio, then push Queue for audio thread

At this time main（） The function is greatly simplified ：

using namespace std;
int main(int argc, char* argv[])
{
    
    QApplication a(argc, argv);
    Xplay2 w;
    w.show();
    xdemuxthread dt;
    dt.open("E:\\ffmpeg\\test222.mp4",w.ui.openGLWidget);
    dt.start();
    return a.exec();
}