moveToThread 的样例

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

上一篇:用户案例 | 腾讯小视频&转码平台云原生容器化之路


下一篇:面试官:Java- 线程池中的线程复用是如何实现的?