main.cpp
#include <QCoreApplication>
#include "Controller.h"
using namespace std;
int main(int argc,char *argv[])
{
QCoreApplication a(argc,argv);
qDebug() << "main thread:" << QThread::currentThreadId();
Controller* controller = new Controller();
emit controller->operate("copy");
a.exec();
}
Controller.h
#include <QThread>
class Controller : public QObject
{
Q_OBJECT
public:
Controller(QObject* parent = nullptr);
~Controller();
public slots:
void handleResults(const QString &des);
signals:
void operate(const QString &cmd);
private:
QThread thread;
};
Controller.cpp
#include "Controller.h"
#include "Worker.h"
#include <QDebug>
Controller::Controller(QObject* parent)
: QObject(parent)
{
Worker *worker = new Worker();
worker->moveToThread(&thread);
connect(&thread, &QThread::finished, worker, &QObject::deleteLater);
connect(this, &Controller::operate, worker, &Worker::doSomething);
connect(worker, &Worker::resultNotify, this, &Controller::handleResults);
thread.start();
}
Controller::~Controller()
{
thread.quit();
thread.wait();
}
void Controller::handleResults(const QString &des)
{
qDebug() << "handleResults()" << des << "thread:" << QThread::currentThreadId();
}
Worker.h
#include <QObject>
class Worker : public QObject
{
Q_OBJECT
public:
explicit Worker(QObject *parent = nullptr);
~Worker();
public slots:
void doSomething(const QString& cmd);
signals:
void resultNotify(const QString& des);
};
Worker.cpp
#include <QDebug>
#include <QThread>
#include "Worker.h"
Worker::Worker(QObject *parent)
: QObject(parent)
{
qDebug() << "Worker()" << "thread:" << QThread::currentThreadId();
}
Worker::~Worker()
{
qDebug() << "~Worker()" << "thread:" << QThread::currentThreadId();
}
void Worker::doSomething(const QString &cmd)
{
qDebug() << "doSomething()" << cmd << "thread:" << QThread::currentThreadId();
//startRecord();
emit resultNotify("doSomething ok!");
}
输出
xz@xiaqiu:~/study/csdn/rtmp/audio_to_rtmp/qt_audio_rtmp/build$ ./qt_audio_rtmp
main thread: 0x7f117b18f7c0
Worker() thread: 0x7f117b18f7c0
doSomething() "copy" thread: 0x7f117a3ad700
handleResults() "doSomething ok!" thread: 0x7f117b18f7c0