Qt 中线程的使用及中线程，以及常见问题

QThread的常见特性：

run()是线程的入口，就像main()对于应用程序的作用。QThread中对run()的默认实现调用了exec()，从而创建一个QEventLoop对象，由其处理该线程事件队列（每一个线程都有一个属于自己的事件队列）中的事件。简单用代码描述如下：

[cpp]view plain copy
int QThread::exec()  
{  
//...  
    QEventLoop eventLoop;  
    int returnCode = eventLoop.exec();  
//...  
    return returnCode;  
}  
   
int QEventLoop::exec(ProcessEventsFlags flags)  
{  
//...  
    while (!d->exit) {  
        while (!posted_event_queue_is_empty) {  
            process_next_posted_event();  
        }  
    }  
//...  
}  

由此可见，exec()在其内部不断做着循环遍历事件队列的工作，调用QThread的quit()或exit()方法使停止工作，尽量不要使用terminate()，该方法过于粗暴，造成资源不能释放，甚至互斥锁还处于加锁状态。

1.旧的使用方式：

[cpp]view plain copy
#include "QThread"  
#include "QMutexLocker"  
#include "QMutex"  
class Thread:public QThread  
{  
    Q_OBJECT  
public:  
    Thread();  
    void stop();  
private:  
    bool m_stopFlag;  
    QMutex mutex;  
protected:  
    void run();  
};  
Thread::Thread()  
{  
    m_stopFlag = false;  
}  
   
void Thread::stop()  
{  
    QMutexLocker locker(&mutex);  
    m_stopFlag = true;  
}  
   
void Thread::run()  
{  
    while(1){  
        {  
            QMutexLocker locker(&mutex);  
            if(m_stopFlag)  
                break;  
        }  
        qDebug()<<"This is in thread["<<currentThreadId()<<"]."<<(int)currentThread();  
        sleep(2);  
    }  
    m_stopFlag = false;  
}  

[cpp]view plain copy
int main(int argc, char *argv[])  
{  
    QCoreApplication a(argc, argv);  
    qDebug()<<"From main thread: "<<QThread::currentThreadId();  
   
    Thread t;  
    QObject::connect(&t, SIGNAL(finished()), &a, SLOT(quit()));  
    t.start();  
    return a.exec();  
}  

这是qt4.6及之前的使用方法，这种方式本没有什么错误，可以处理我们的绝大多数需求。Thread对象本身工作在主线程下，即使调用的t.stop()方法，它也是工作在主线程下，只有run()范围内的代码工作在次线程中。

[cpp]view plain copy
class WorkerThread : public QThread  
{  
    Q_OBJECT  
  
    void run() Q_DECL_OVERRIDE {  
        QString result;  
        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();  
}  

从Qt4.8起，可以释放运行刚刚结束的线程对象，通过连接finished()信号到QObject::deleteLater()。

2.推荐的使用方式：

[cpp]view plain copy
#include <QtCore>  
class Worker : public QObject  
{  
    Q_OBJECT  
private slots:  
    void onTimeout()  
    {  
        qDebug()<<"Worker::onTimeout get called from?: "<<QThread::currentThreadId();  
    }  
};  

[cpp]view plain copy
#include "main.moc"  
int main(int argc, char *argv[])  
{  
    QCoreApplication a(argc, argv);  
    qDebug()<<"From main thread: "<<QThread::currentThreadId();  
   
    QThread t;  
    QTimer timer;  
    Worker worker;  
   
    QObject::connect(&timer, SIGNAL(timeout()), &worker, SLOT(onTimeout()));  
    timer.start(1000);  
   
    worker.moveToThread(&t);  
   
    t.start();  
   
    return a.exec();  
}  

这是Qt4.7及以后版本推荐的工作方式。其主要特点就是利用Qt的事件驱动特性，将需要在次线程中处理的业务放在独立的模块（类）中，由主线程创建完该对象后，将其移交给指定的线程，且可以将多个类似的对象移交给同一个线程。在这个例子中，信号由主线程的QTimer对象发出，之后Qt会将关联的事件放到worker所属线程的事件队列。由于队列连接的作用，在不同线程间连接信号和槽是很安全的。
说说connect最后一个参数，连接类型：
1)自动连接(AutoConnection)，默认的连接方式，如果信号与槽，也就是发送者与接受者在同一线程，等同于直接连接；如果发送者与接受者处在不同线程，等同于队列连接。
2)直接连接(DirectConnection)，当信号发射时，槽函数立即直接调用。无论槽函数所属对象在哪个线程，槽函数总在发送者所在线程执行。

3)队列连接(QueuedConnection)，当控制权回到接受者所在线程的事件循环时，槽函数被调用。槽函数在接受者所在线程执行。

[cpp]view plain copy
class Worker : public QObject  
{  
    Q_OBJECT  
  
public slots:  
    void doWork(const QString meter) {  
        // ...  
        emit resultReady(result);  
    }  
    void stopWork(){  
        //...  
    }  
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(this, &Controller::kill, worker, &Worker::stopWork);  
        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 &);  
    void kill();  
};  

如果看不懂还可以看下面的例子：

Qt 中线程的使用及中线程，以及常见问题

使用方式:

Qt 中线程的使用及中线程，以及常见问题

解释：pTh实际上是新的线程，自己建的类通过moveToThread 绑定到新的线程中，通过connect连接将开始信号绑定到自己定义的函数当中。通过pTh->start()来开启线程。.quit 和.exit来关闭线程，当线程中有循环没结束时，是不能够正常退出的，可以通过isRunning() 和isFinished()来查看是否退出和线程的状态。

.如果一个线程运行完成，就会结束。可很多情况并非这么简单，由于某种特殊原因，当线程还未执行完时，我们就想中止它。
不恰当的中止往往会引起一些未知错误。比如：当关闭主界面的时候，很有可能次线程正在运行，这时，就会出现如下提示：
QThread: Destroyed while thread is still running
这是因为次线程还在运行，就结束了UI主线程，导致事件循环结束。这个问题在使用线程的过程中经常遇到，尤其是耗时操作。
在此问题上，常见的两种人：
1.直接忽略此问题。
2.强制中止 - terminate()。
大多数情况下，当程序退出时，次线程也许会正常退出。这时，虽然抱着侥幸心理，但隐患依然存在，也许在极少数情况下，就会出现Crash。
正如前面提到过terminate()，比较危险，不鼓励使用。线程可以在代码执行的任何点被终止。线程可能在更新数据时被终止，从而没有机会来清理自己，解锁等等。。。总之，只有在绝对必要时使用此函数。
所以，我们应该采取合理的措施来优雅地结束线程，一般思路：
1.发起线程退出操作，调用quit()或exit()。
2.等待线程完全停止，删除创建在堆上的对象。

3.适当的使用wait()（用于等待线程的退出）和合理的算法。

有循环要退出线程时就需要通过下面几种方法（需要自己去尝试那种适合你）

1.使用新方式，子线程中的槽都在子线程中运行，主线程中的槽都在主线程中运行，信号和槽默认使用自动连接(AutoConnection)。值得注意的是，如果槽doWork中有耗时操作，比如说while循环，主线程的信号kill子线程是不会响应的，除非使用直接连接(DirectConnection)，connect(this, &Controller::kill, worker, &Worker::stopWork, Qt::DirectConnection);，此时，槽stopWork工作于主线程。

2.QMutex互斥锁 + bool成员变量。
这种方式是Qt4.x中比较常用的，主要是利用“QMutex互斥锁 + bool成员变量”的方式来保证共享数据的安全性（可以完全参照下面的requestInterruption()源码写法）。

[cpp]view plain copy
#include <QThread>  
#include <QMutexLocker>  
  
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() Q_DECL_OVERRIDE {  
        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:  
    bool m_bStopped;  
    QMutex m_mutex;  
};  

为什么要加锁？很简单，是为了共享数据段操作的互斥。
何时需要加锁？在形成资源竞争的时候，也就是说，多个线程有可能访问同一共享资源的时候。
当主线程调用stop()更新m_bStopped的时候，run()函数也极有可能正在访问它（这时，他们处于不同的线程），所以存在资源竞争，因此需要加锁，保证共享数据的安全性。

3.Qt5以后：requestInterruption() + isInterruptionRequested()
这两个接口是Qt5.x引入的，使用很方便：

[cpp]view plain copy
class WorkerThread : public QThread  
{  
    Q_OBJECT  
  
public:  
    explicit WorkerThread(QObject *parent = 0)  
        : QThread(parent)  
    {  
    }  
  
    ~WorkerThread() {  
        // 请求终止  
        requestInterruption();  
        quit();  
        wait();  
    }  
  
protected:  
    virtual void run() Q_DECL_OVERRIDE {  
        // 是否请求终止  
        while (!isInterruptionRequested())  
        {  
            // 耗时操作  
        }  
    }  
};  

在耗时操作中使用isInterruptionRequested()来判断是否请求终止线程，如果没有，则一直运行；当希望终止线程的时候，调用requestInterruption()即可。
正如侯捷所言：「源码面前，了无秘密」。如果还心存疑虑，我们不妨来看看requestInterruption()、isInterruptionRequested()的源码：

[cpp]view plain copy
void QThread::requestInterruption()  
{  
    Q_D(QThread);  
    QMutexLocker locker(&d->mutex);  
    if (!d->running || d->finished || d->isInFinish)  
        return;  
    if (this == QCoreApplicationPrivate::theMainThread) {  
        qWarning("QThread::requestInterruption has no effect on the main thread");  
        return;  
    }  
    d->interruptionRequested = true;  
}  
  
bool QThread::isInterruptionRequested() const  
{  
    Q_D(const QThread);  
    QMutexLocker locker(&d->mutex);  
    if (!d->running || d->finished || d->isInFinish)  
        return false;  
    return d->interruptionRequested;  
}  

^_^，内部实现居然也用了互斥锁QMutex，这样我们就可以放心地使用了。

4.设置一个bool类型私有变量，放在循环前面，然后定义一个public函数，函数去改变bool类型的值，就可以跳出循环。

3.GUI界面假死的处理
在GUI程序中，主线程也叫GUI线程，因为它是唯一被允许执行GUI相关操作的线程。对于一些耗时的操作，如果放在主线程中，就是出现界面无法响应的问题。这种问题的解决一种方式是，把这些耗时操作放到次线程中，还有一种比较简单的方法：在处理耗时操作中频繁调用QApplication::processEvents()。这个函数告诉Qt去处理那些还没有被处理的各类事件，然后再把控制权返还给调用者。

[cpp]view plain copy
QElapsedTimer et;  
et.start();  
while(et.elapsed()<300)  
    QCoreApplication::processEvents();  

参考链接：https://blog.****.net/caoshangpa/article/details/52784860

参考链接：https://blog.****.net/caoshangpa/article/details/62421334

Qt 中线程的使用及中线程，以及常见问题

相关推荐