Qt QThread类

参考博客1：QThread详解
参考博客2：Qt之线程（QThread）
参考博客3：QT 多线程程序设计
参考博客4：Qt之QThread（深入理解）

---

QThread类提供了一个平台无关的方式来管理线程。
一个QThread对象在程序控制中管理一个线程。线程在run()中开始执行。默认情况下，run()通过调用exec()启动事件循环并在线程里运行一个Qt的事件循环。
执行结束时，将会返回run()函数的执行结果。 当线程启动、结束、终结时，他会通过发送一个信号来通知你。你可以通过isFinished()和isrunning来查询线程的状态。
QThread 的两种使用方法：
1、子类化 QThread（不使用事件循环）。
这是官方手册、例子以及相关书籍中都介绍的一种常用的方法。
a. 子类化 QThread,创建对象，并调用start()函数
b. 重载 run 函数，run函数内有一个while或for的死循环（模拟耗时操作）
c. 设置一个标记为来控制死循环的退出。

2、子类化 QObject
a. 子类化 QObject
b. 定义槽函数
c. 将该子类的对象moveToThread到新线程中

若程序退出时，次线程还在运行，未正常退出
我们应该采取合理的措施来优雅地结束线程，一般思路：
发起线程退出操作，调用quit()或exit()。
等待线程完全停止，删除创建在堆上的对象。
适当的使用wait()（用于等待线程的退出）和合理的算法。

下面的代码按照参考博客4(使用Qt5)修改而来，可在Qt4.8上面运行：
使用的方法1

运行图.png

WorkerThread.h

#ifndef WORKERTHREAD_H
#define WORKERTHREAD_H

#include <QThread>
#include <QMutex>
#include <QDebug>

class WorkerThread : public QThread
{
    Q_OBJECT

public:
    explicit WorkerThread(QObject *parent = 0)
        : QThread(parent),
          m_bStopped(false)
    {
        qDebug() << "Worker Thread : " << QThread::currentThreadId();
    }

    ~WorkerThread()
    {
        stop();
        quit();
        wait();//
    }

    void stop()
    {
        qDebug() << "Worker Stop Thread : " << QThread::currentThreadId();
        QMutexLocker locker(&m_mutex);
        m_bStopped = true;
    }
protected:
    virtual void run() {
        qDebug() << "Worker Run Thread : " << QThread::currentThreadId();
        int nValue = 0;
        while (nValue < 100)
        {
            // 休眠50毫秒
            msleep(50);
            ++nValue;

            // 准备更新
            emit resultReady(nValue);

            // 检测是否停止
            {
                QMutexLocker locker(&m_mutex);
                if (m_bStopped)
                    break;
            }
            // locker超出范围并释放互斥锁
        }
    }
signals:
    void resultReady(int value);


private:
    //QMutex互斥锁 + bool成员变量，
    bool m_bStopped;
    QMutex m_mutex;

};

#endif // WORKERTHREAD_H

QMyWidget.h

#ifndef QMYWIDGET_H
#define QMYWIDGET_H

#include <QWidget>
#include <QProgressBar>
#include "WorkerThread.h"

class QMyWidget : public QWidget
{
    Q_OBJECT
public:
    explicit QMyWidget(QWidget *parent = 0);
    ~QMyWidget();

private slots:
    // 更新进度
    void handleResults(int value);

    // 开启线程
    void startThread();

private:
    QProgressBar *m_pProgressBar;
    WorkerThread m_workerThread;
};
#endif

QMyWidget.cpp

#include "QMyWidget.h"
#include <QPushButton>
#include <QVBoxLayout>


QMyWidget:: QMyWidget(QWidget *parent)
        : QWidget(parent)
    {
        qDebug() << "Main Thread : " << QThread::currentThreadId();

        // 创建开始按钮、进度条
        QPushButton *pStartButton = new QPushButton(this);
        m_pProgressBar = new QProgressBar(this);

        //设置文本、进度条取值范围
        pStartButton->setText(QString::fromLocal8Bit("开始"));
        m_pProgressBar->setFixedHeight(25);
        m_pProgressBar->setRange(0, 100);
        m_pProgressBar->setValue(0);

        QVBoxLayout *pLayout = new QVBoxLayout();
        pLayout->addWidget(pStartButton, 0, Qt::AlignHCenter);
        pLayout->addWidget(m_pProgressBar);
        pLayout->setSpacing(50);
        pLayout->setContentsMargins(10, 10, 10, 10);
        setLayout(pLayout);

        // 连接信号槽
        connect(pStartButton, SIGNAL(clicked(bool)), this, SLOT(startThread()));


        connect(&m_workerThread, SIGNAL(resultReady(int)), this, SLOT(handleResults(int)));
        // 线程结束后，自动销毁
        //connect(&m_workerThread, SIGNAL(finished()), &m_workerThread, SLOT(deleteLater()));
    }

    QMyWidget::~QMyWidget(){}


    // 更新进度
    void QMyWidget::handleResults(int value)
    {
        qDebug() << "Handle Thread : " << QThread::currentThreadId();
        m_pProgressBar->setValue(value);
    }

    // 开启线程
    void QMyWidget::startThread()
    {
        if(!m_workerThread.isRunning()){
                m_workerThread.start();
        }
    }

main.cpp

#include <QtGui/QApplication>
#include "QMyWidget.h"

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    QMyWidget w;
    w.show();   
    return a.exec();
}