QThread

常用函数

• 构造函数

• isFinished()

• isRunning()

• setPriority() 优先级

• exit()调用后可能不会立马退出，因为线程 可能还有函数未执行完成，需要后面调用wait()

• wait()

• terminate()直接终止

• msleep() sleep() usleep() 毫秒 秒 微秒

第一种使用方式

自己创建一个线程对象继承自QThread，重写run方法，然后调用start()就可以直接调用run方法了

注意：

• 在 Qt 中在子线程中不要操作程序中的窗口类型对象，不允许，如果操作了程序就挂了

• 只有主线程才能操作程序中的窗口对象，默认的线程就是主线程，自己创建的就是子线程

这种在程序中添加子线程的方式是非常简单的，但是也有弊端，假设要在一个子线程中处理多个任务，所有的处理逻辑都需要写到run()函数中，这样该函数中的处理逻辑就会变得非常混乱，不太容易维护。

第二种使用方式

1. 创建一个新的类（工作类对象MyWork），必须继承自QObject

2. 在类中添加一个成员函数，函数名称、签名等可自定义

3. 在主线程中创建一个QThread对象QThread* sub = new QThread;

4. 在主线程中创建工作类对象，千万不能指定父对象 MyWork* work = new MyWork

5. 将工作类对象移动到子线程中work->moveToThread(sub)

6. 启动子线程sub.start(),但是线程并没有工作

7. 调用工作类对象中的工作函数，子线程开始工作

//mywork.h#ifndef MYWORK_H#define MYWORK_H#include <QObject>class MyWork : public QObject{
    Q_OBJECTpublic:
    explicit MyWork(QObject *parent = nullptr);

    // 工作函数
    void working();signals:
    void curNumber(int num);public slots:};#endif // MYWORK_H

//mywork.cpp#include "mywork.h"#include <QDebug>#include <QThread>MyWork::MyWork(QObject *parent) : QObject(parent){}void MyWork::working(){
    qDebug() << "当前线程对象的地址: " << QThread::currentThread();

    int num = 0;
    while(1)
    {
        emit curNumber(num++);
        if(num == 10000000)
        {
            break;
        }
        QThread::usleep(1);
    }
    qDebug() << "run() 执行完毕, 子线程退出...";}

//mainwindow.cpp#include "mainwindow.h"#include "ui_mainwindow.h"#include <QThread>#include "mywork.h"#include <QDebug>MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow){
    ui->setupUi(this);

    qDebug() << "主线程对象的地址: " << QThread::currentThread();

    // 创建线程对象
    QThread* sub = new QThread;
    // 创建工作的类对象
    // 千万不要指定给创建的对象指定父对象
    // 如果指定了: QObject::moveToThread: Cannot move objects with a parent
    MyWork* work = new MyWork;
    // 将工作的类对象移动到创建的子线程对象中
    work->moveToThread(sub);
    // 启动线程
    sub->start();
    // 让工作的对象开始工作, 点击开始按钮, 开始工作
    connect(ui->startBtn, &QPushButton::clicked, work, &MyWork::working);
    // 显示数据
    connect(work, &MyWork::curNumber, this, [=](int num)
    {
        ui->label->setNum(num);
    });}MainWindow::~MainWindow(){
    delete ui;}

线程资源释放

1. 直接利用对象树，在创建对象的时候制定父对象

2. 直接析构，如果是在函数范围内声明的QThread对象，析构函数不能够访问可以这样

connect(this,&MainWindow::destroy,this,[=](){//主窗体析构的时候会触发destroy信号
    t1->quit();
    t1->wait();
    t1->deleteLater();});

QThreadPool

Qt 中的 QThreadPool 类管理了一组 QThreads, 里边还维护了一个任务队列。QThreadPool 管理和回收各个 QThread 对象，以帮助减少使用线程的程序中的线程创建成本。每个Qt应用程序都有一个全局 QThreadPool 对象，可以通过调用 globalInstance() 来访问它。也可以单独创建一个 QThreadPool 对象使用。

// 获取和设置线程中的最大线程个数int maxThreadCount() const;void setMaxThreadCount(int maxThreadCount);// 给线程池添加任务, 任务是一个 QRunnable 类型的对象// 如果线程池中没有空闲的线程了, 任务会放到任务队列中, 等待线程处理void QThreadPool::start(QRunnable * runnable, int priority = 0);// 如果线程池中没有空闲的线程了, 直接返回值, 任务添加失败, 任务不会添加到任务队列中bool QThreadPool::tryStart(QRunnable * runnable);// 线程池中被激活的线程的个数(正在工作的线程个数)int QThreadPool::activeThreadCount() const;// 尝试性的将某一个任务从线程池的任务队列中删除, 如果任务已经开始执行就无法删除了bool QThreadPool::tryTake(QRunnable *runnable);// 将线程池中的任务队列里边没有开始处理的所有任务删除, 如果已经开始处理了就无法通过该函数删除了void QThreadPool::clear();// 在每个Qt应用程序中都有一个全局的线程池对象, 通过这个函数直接访问这个对象static QThreadPool * QThreadPool::globalInstance();

QRunnable

在 Qt 中使用线程池需要先创建任务，添加到线程池中的每一个任务都需要是一个 QRunnable 类型，因此在程序中需要创建子类继承 QRunnable 这个类，然后重写 run() 方法，在这个函数中编写要在线程池中执行的任务，并将这个子类对象传递给线程池，这样任务就可以被线程池中的某个工作的线程处理掉了。QRunnable 类 常用函数不多，主要是设置任务对象传给线程池后，是否需要自动析构。

// 在子类中必须要重写的函数, 里边是任务的处理流程[pure virtual] void QRunnable::run();// 参数设置为 true: 这个任务对象在线程池中的线程中处理完毕, 这个任务对象就会自动销毁// 参数设置为 false: 这个任务对象在线程池中的线程中处理完毕, 对象需要程序猿手动销毁void QRunnable::setAutoDelete(bool autoDelete);// 获取当前任务对象的析构方式,返回true->自动析构, 返回false->手动析构bool QRunnable::autoDelete() const;class MyWork : public QObject, public QRunnable{
    Q_OBJECTpublic:
    explicit MyWork(QObject *parent = nullptr)
    {
        // 任务执行完毕,该对象自动销毁
        setAutoDelete(true);
    }
    ~MyWork();

    void run() override{}}

使用案例

//mywork.hclass MyWork :public QRunnable{
    Q_OBJECTpublic:
    explicit MyWork();
    ~MyWork();

    void run() override;}MyWork::MyWork() : QRunnable(){
    // 任务执行完毕,该对象自动销毁
    setAutoDelete(true);}void MyWork::run(){
    // 业务处理代码
    ......}//mainwindowMainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow){
    ui->setupUi(this);

    // 线程池初始化，设置最大线程池数
    QThreadPool::globalInstance()->setMaxThreadCount(4);
    // 添加任务
    MyWork* task = new MyWork;
    QThreadPool::globalInstance()->start(task);    }