一、线程
QT主线程称为GUI线程,负责初始化界面并监听事件循环,并根据事件处理做出界面上的反馈。如果把一些比较复杂或者费时的操作放在主线程中,界面就会出现卡顿或者无响应的现象。一般主线程负责影响界面上的操作, 子线程负责负责费时的数据处理。
二、使用多线程有什么好处
1. 提高应用界面的响应速度。
这对于开发图形界面程序尤其重要,当一个操作耗时很长时(比如大批量I/O或大量矩阵变换等CPU密集操作),整个系统都会等待这个操作,程序就不能响应键盘、鼠标、菜单等操作,而使用多线程技术可将耗时长的操作置于一个新的线程,从而不会影响到主GUI线程,从而避免上述问题。
2. 使多核心CPU系统更加有效。
当线程数不大于CPU核数时,操作系统可以调度不同的线程运行于不同的CPU核上。
3. 改善程序结构。
一个既长又复杂的进程可以考虑分为多个线程,成为独立或半独立的运行部分,这样有利于程序的理解和维护。
界面操作只能由主线程来操作,其他线程负责处理复杂数据.
三、QThread类常用的方法
Public FunctionsQThread(QObject *parent = 0) //构造函数 //pthread_createbool isFinished() const //判断线程是否退出bool wait(unsigned long time = ULONG_MAX) //pthread_join(&id)//等待某个线程结束,最多等待time ms,如果时间没有设置,那么永远等待。Public Slotsvoid start(Priority priority = InheritPriority) //启动线程必须使用startvoid terminate()-->杀死线程 //pthread_cancelStatic Public MembersQt::HANDLE currentThreadId() [static] //得到当前执行者线程ID,可以直接qDebugvoid sleep(unsigned long secs) [static]void msleep(unsigned long msecs) [static]void usleep(unsigned long usecs) [static]睡眠函数不能在主线程调用,会造成界面卡死。Protected Functions virtual void run(); //启动新线程不能直接调用run,需要调用start接口,//start会启动新线程,然后执行run里的代码块。
四、重写run方法创建线程步骤
1、自定义类继承于QThread。
2、重写 run 函数,run函数内有一个 while 或 for 的循环:执行耗时操作。
3、在主线程中,创建自定类类型的对象,调用start方法启动线程, run方法就是新线程的入口函数。
4、主线程通过调用子线程的公有方法传递参数给子线程。
5、子线程通过信号与槽传递参数给主线程。
6、通过quit+wait方法,通知线程退出,回收线程资源。但wait是一个阻塞方法,如果线程没有退出,wait阻塞等待。一般子线程会设置一个标记为来控制循环的退出,并提供一个公有方法设置标记值。当通知线程退出时,在主线程中调用设置标志的公有方法,将循环条件设为假,线程退出,这时wait回收子线程资源不会造成阻塞。
7、关闭窗口时,要对其他子线程进行管理. 关闭窗口时,窗口会发出destroyed信号,可以通过连接该信号来管理子线程。在QT6中,可能不执行这个信号的槽方法,可以通过重现closeEvent事件来处理。
案例需求:在子线程中, 1秒中输出1个整型的数字, 将数字传到主线程, 在主线程的Label中显示。
代码:
mtthread.h
#ifndef MTTHREAD_H
#define MTTHREAD_H#include <QObject>
#include <QThread>
#include <QDebug>
class MtThread : public QThread
{Q_OBJECT
public:explicit MtThread(QObject *parent = nullptr);void run();void set_flag(int flag);
signals:void my_signal(int n);
public slots:private:int flag = 1;
};#endif // MTTHREAD_H
widget.h
#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include "mtthread.h"
namespace Ui {
class Widget;
}class Widget : public QWidget
{Q_OBJECTpublic:explicit Widget(QWidget *parent = nullptr);~Widget();
private slots:void on_pushButton_clicked();void on_pushButton_2_clicked();void my_signal_slot(int n);private:Ui::Widget *ui;MtThread *thread;
};#endif // WIDGET_H
mtthread.cpp
#include "mtthread.h"MtThread::MtThread(QObject *parent) : QThread(parent)
{}void MtThread::run()
{static int n = 0;qDebug()<<"current thread:"<<QThread::currentThread();while(flag){qDebug()<<"n = "<<n++;emit my_signal(n); // 发送信号sleep(1);}
}void MtThread::set_flag(int flag)
{this->flag = flag;
}
widget.cpp
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent) :QWidget(parent),ui(new Ui::Widget)
{ui->setupUi(this);thread = new MtThread(this);qDebug()<<"main thread:"<<QThread::currentThread();connect(this,&Widget::destroyed,this,&Widget::on_pushButton_2_clicked); // 直接点击 X 也能销毁线程connect(thread,&MtThread::my_signal,this,&Widget::my_signal_slot);
}Widget::~Widget()
{delete ui;
}void Widget::on_pushButton_clicked()
{thread->start(); // 启动线程
}void Widget::on_pushButton_2_clicked()
{thread->quit(); // (通知)线程退出 (如果任务没做完不会结束!)// 线程结束的条件 --> run()运行结束 --> 循环条件为假thread->set_flag(0);thread->wait(); // 回收线程资源,如果线程没有退出,wait()是一个阻塞函数this->close();
}void Widget::my_signal_slot(int n)
{ui->label->setText(QString::number(n));
}
输出:
五、moveToThread方法创建线程步骤
1、自定义类继承于QObject, 实现线程的入口函数,方法名自定义。
2、主线程中实例化自定义类对象和QThread类型的对象。
3、将自定义对象移动到QThread线程中。
4、启动线程, 必须通过信号与槽,让自定义类类型对象调用相应的方法,这个方法就是放到线程中执行(注意:启动线程调用start方法,在这个方法中会发送started信号)。
5、主线程通过调用子线程的公有方法传递参数给子线程。
6、子线程通过信号与槽传递参数给主线程。
7、通过quit+wait方法,通知线程退出,回收线程资源。但wait是一个阻塞方法,如果线程没有退出,wait阻塞等待。一般子线程会设置一个标记为来控制循环的退出,并提供一个公有方法设置标记值。当通知线程退出时,在主线程中调用设置标志的公有方法,将循环条件设为假,线程退出,这时wait回收子线程资源不会造成阻塞。
8、关闭窗口时,要对其他子线程进行管理. 关闭窗口时,窗口会发出destroyed信号,可以通过连接该信号来管理子线程。在QT6中,可能不执行这个信号的槽方法,可以通过重现closeEvent事件来处理。
案例需求:在子线程中, 1秒中输出1个整型的数字, 将数字传到主线程, 在主线程的Label中显示。
代码:
mytask.h
#ifndef MYTASK_H
#define MYTASK_H#include <QObject>
#include <QDebug>
#include <QThread>
class MyTask : public QObject
{Q_OBJECT
public:explicit MyTask(QObject *parent = nullptr);void thread_task();void set_flag(int flag);
signals:void my_signal(int n);
public slots:private:int flag = 1;
};#endif // MYTASK_H
widget.h
#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QDebug>
#include <QThread>
#include "mytask.h"namespace Ui {
class Widget;
}class Widget : public QWidget
{Q_OBJECTpublic:explicit Widget(QWidget *parent = nullptr);~Widget();private slots:void on_pushButton_clicked();void on_pushButton_2_clicked();private:Ui::Widget *ui;QThread *thread;MyTask *task;
};#endif // WIDGET_H
mytask.cpp
#include "mytask.h"MyTask::MyTask(QObject *parent) : QObject(parent)
{}void MyTask::thread_task()
{static int n = 0;while(flag){qDebug()<<"n = "<<n++;emit my_signal(n);QThread::sleep(1);}
}void MyTask::set_flag(int flag)
{this->flag = flag;
}
widget.cpp
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent) :QWidget(parent),ui(new Ui::Widget)
{ui->setupUi(this);thread = new QThread(this);qDebug()<<"main thread:"<<QThread::currentThread();task = new MyTask; // 不能指定父对象task->moveToThread(thread); // 把task移动到thread线程中connect(thread,&QThread::started,task,&MyTask::thread_task); // 不能直接调用MyTask里的函数,只能通过槽连接connect(this,&Widget::destroyed,this,&Widget::on_pushButton_2_clicked); // 直接点击 X 也能销毁线程connect(task,&MyTask::my_signal,this,[=](int n){ // 只能在主线程对界面进行操作this->ui->label->setText(QString::number(n));});
}Widget::~Widget()
{delete ui;
}void Widget::on_pushButton_clicked()
{thread->start(); // 启动线程,发送start()信号
}void Widget::on_pushButton_2_clicked()
{thread->quit();task->set_flag(0);thread->wait();
}
输出:
案例需求:通过线程,实现电子时钟。
代码:
mytime.h
#ifndef MYTIME_H
#define MYTIME_H#include <QObject>
#include <QDebug>
#include <QThread>
#include <QDateTime>
class MyTime : public QObject
{Q_OBJECT
public:explicit MyTime(QObject *parent = nullptr);void thread_time();void set_flag(int flag);
signals:void my_signal(QString datatime);
public slots:private:int flag = 1;
};#endif // MYTIME_H
widget.h
#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QDebug>
#include <QThread>
#include "mytime.h"namespace Ui {
class Widget;
}class Widget : public QWidget
{Q_OBJECTpublic:explicit Widget(QWidget *parent = nullptr);~Widget();private slots:void on_pushButton_clicked();void on_pushButton_2_clicked();private:Ui::Widget *ui;QThread *thread;MyTime *time;
};#endif // WIDGET_H
mytime.cpp
#include "mytime.h"MyTime::MyTime(QObject *parent) : QObject(parent)
{}void MyTime::thread_time()
{while(flag){QDateTime currentTime = QDateTime::currentDateTime();QString formattedTime = currentTime.toString("hh:mm:ss");qDebug() << formattedTime;emit my_signal(formattedTime);QThread::sleep(1);}
}void MyTime::set_flag(int flag)
{this->flag = flag;
}
widget.cpp
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent) :QWidget(parent),ui(new Ui::Widget)
{ui->setupUi(this);thread = new QThread(this);time = new MyTime; // 不能指定父对象ui->lcdNumber->setDigitCount(8);time->moveToThread(thread); // 移动到thread线程中connect(thread,&QThread::started,time,&MyTime::thread_time);connect(this,&Widget::destroyed,this,&Widget::on_pushButton_2_clicked); // 直接点击 X 也能销毁线程connect(time,&MyTime::my_signal,this,[=](QString datatime){ // 只能在主线程对界面进行操作this->ui->lcdNumber->display(datatime);});
}
Widget::~Widget()
{delete ui;
}void Widget::on_pushButton_clicked()
{thread->start();
}void Widget::on_pushButton_2_clicked()
{thread->quit();time->set_flag(0);thread->wait();
}
输出:
六、connect最后一个参数
表示连接类型,默认是自动连接。有如下几种选择:
Qt::AutoConnection (0)
这是默认的连接类型。Qt会根据信号发射者接收者(slot所在的对象)是否位于发射信号的线程中,自动选择使用Qt::DirectConnection
或Qt::QueuedConnection
。如果接收者和发射者位于同一线程,则使用Qt::DirectConnection
;否则,使用Qt::QueuedConnection
。
Qt::DirectConnection (1)
当信号被发射时,槽函数会立即在同一线程中被调用。这种连接类型适用于槽函数不需要跨线程执行的场景,因为它避免了线程切换的开销。
Qt::QueuedConnection (2)
信号被发射后,槽函数的调用会被排入接收者对象所在线程的事件循环中。这意味着槽函数将在接收者对象的线程中执行,但不一定是在信号发射后立即执行。这种连接类型适用于跨线程通信,确保了线程安全。
Qt::BlockingQueuedConnection (3)
这种连接类型与Qt::QueuedConnection
类似,但有一个关键区别:发射信号的线程会在槽函数执行完毕并返回之前被阻塞。这意呀着,如果接收者(槽函数)位于发射信号的同一线程中,使用这种连接类型将导致死锁,因为发射信号的线程会等待它自己来完成槽函数的执行。
Qt::UniqueConnection (0x80)
这不是一个独立的连接类型,而是一个可以与上述任何连接类型通过位或(bitwise OR)操作组合使用的标志。当设置了Qt::UniqueConnection
时,如果指定的信号和槽之间的连接已经存在,QObject::connect()
函数将不会建立新的连接,并返回false
。这有助于避免重复连接同一信号到同一槽,尤其是在动态连接信号和槽时非常有用。