Qt线程使用的两种方法

发表于

QThread类提供一种独立于平台的线程管理方式。

方法1

  一个QThread实例管理程序中的一个线程。QThread的执行开始于run()。默认情况下，run()通过调用exec()启动事件循环，并在线程内运行Qt事件循环。
  你可以使用QObject::moveToThread()将工作对象移动到线程中使用。

  • 示例：
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    class Worker : public QObject
    {
        Q_OBJECT
    public slots:
        void doWork(const QString &parameter) {
            QString result;
            /* ... here is the expensive or blocking operation ... */
            emit resultReady(result);
        }

    signals:
        void resultReady(const QString &result);
    };

    class Controller : public QObject
    {
        Q_OBJECT
        QThread workerThread;
    public:
        Controller() {
            Worker *worker = new Worker;
            worker->moveToThread(&workerThread);
            connect(&workerThread, &QThread::finished, worker, &QObject::deleteLater);
            connect(this, &Controller::operate, worker, &Worker::doWork);
            connect(worker, &Worker::resultReady, this, &Controller::handleResults);
            workerThread.start();
        }
        
        ~Controller() {
            workerThread.quit();
            workerThread.wait();
        }
        
    public slots:
        void handleResults(const QString &);
        
    signals:
        void operate(const QString &);
    };

  将线程移动到工作线程内执行。因为在线程中有队列的信号槽连接机制，所以在不同线程中使用信号槽是安全的。

方法2

  另一种单独在线程中执行的方式是继承QThread后重新实现run()函数(run函数内用户的执行操作)。

  • 示例:
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    class WorkerThread : public QThread
    {
        Q_OBJECT
        void run() override {
            QString result;
            /* ... here is the expensive or blocking operation ... */
            emit resultReady(result);
        }
    signals:
        void resultReady(const QString &s);
    };

    void MyObject::startWorkInAThread()
    {
        WorkerThread *workerThread = new WorkerThread(this);
        connect(workerThread, &WorkerThread::resultReady, this, &MyObject::handleResults);
        connect(workerThread, &WorkerThread::finished, workerThread, &QObject::deleteLater);
        workerThread->start();
    }