网站首页 > 技术文章 正文
一、多线程目的
QThread类提供了一个与平台无关的管理线程的方法。
在Qt中建立线程的主要目的就是为了用线程来处理那些耗时的后台操作,比如大量运算,复制大文件,网络传输等。
二、QThread多线程使用方法
使用Qt框架开发应用程序时,使用QThread类可以方便快捷地创建管理多线程。
而多线程之间的通信也可使用Qt特有的“信号-槽”机制实现。
QThread的使用方法有如下两种:
1. 继承QThread类
2. QObject::moveToThread()
2.1 继承QThread方法
第一种方法很简单,也很好理解,写一个类继承QThread类,并重写run()函数,并在主线程中生成一个ChildThread的实例,并调用对象的start()函数
首先定义FileCopyThread类,继承QThread,添加两个signals
//FileCopyThread.h
#ifndef CHILDTHREAD_H
#define CHILDTHREAD_H
#include <QThread>
class FileCopyThread : public QThread
{
Q_OBJECT
public:
explicit FileCopyThread();
~FileCopyThread();
protected:
void run() override; //重写QThread类的虚函数,也是线程子类的入口函数
signals:
void done(); //完成信号
void reportProgress(int precent); //报告完成进度
};
#endif // CHILDTHREAD_H
FileCopyThread.cpp
#include "childthread.h"
#include <QMessageBox>
FileCopyThread::FileCopyThread()
{
}
FileCopyThread::~FileCopyThread()
{
}
void FileCopyThread::run()
{
for (int i = 0; i <= 10; i++)//模拟耗时运算
{
QThread::msleep(500);
emit reportProgress(i*10);
}
emit done();
}
在主线程中调用如下:
FileCopyThread* t = new FileCopyThread;
connect(t, &FileCopyThread::reportProgress, ui->progressBar, &QProgressBar::setValue);
connect(t, SIGNAL(done()), this, SLOT(onCopyFinished()));
t->start();
2.2 QObject::moveToThread
说实话这种方法我没有很理解o(╥﹏╥)o
定义一个普通的QObject派生类FileWorker,然后将其对象move到QThread中。
在定义一个转发类也是QObject子类,起名字叫controller,或者叫dummy。将转发类的信号槽和FileWorker类的信号槽关联起来,这样在主线程中调用转发类的槽函数,或者接收信号就OK了。
大概意思是通过转发类,能使得FileWorker类的槽函数妥当的运行在子线程里面。同时也不需要使用QMutex来进行同步,Qt的事件循环会自己自动处理好这个。
//FileWorker.h
#ifndef FILEWORKER_H
#define FILEWORKER_H
#include <QObject>
#include <QThread>
class FileWorker : public QObject
{
Q_OBJECT
public:
explicit FileWorker(QObject *parent = nullptr);
signals:
void done(); //完成信号
void reportProgress(int precent); //报告完成进度
private slots:
void doWork();//线程需要做的工作
};
#endif // FILEWORKER_H
//FileWorker.cpp
#include "fileworker.h"
#include <QDebug>
FileWorker::FileWorker(QObject *parent) : QObject(parent)
{
}
void FileWorker::doWork()
{
qDebug()<<"from thread doWork slot:" <<QThread::currentThreadId();
for (int i = 0; i <= 10; i++)//模拟耗时运算
{
QThread::msleep(500);
emit reportProgress(i*10);
}
emit done();
}
//Controller.h
#ifndef CONTROLLER_H
#define CONTROLLER_H
#include <QObject>
class Controller : public QObject
{
Q_OBJECT
public:
explicit Controller(QObject *parent = nullptr);
signals:
void sig_copy();
void done(); //完成信号
void reportProgress(int precent); //报告完成进度
public slots:
void startCopy();
};
#endif // CONTROLLER_H
//Controller.cpp
#include "controller.h"
Controller::Controller(QObject *parent) : QObject(parent)
{
}
void Controller::startCopy()
{
emit sig_copy();
}
在主线程中,首先做转发类和worker类的信号槽关联
worker2.moveToThread(&t2);//FileWorker对象moveToThread
connect(&controller2, SIGNAL(sig_copy()), &worker2, SLOT(doWork()));//controller2是这里的转发类,它的信号和fileWorker槽关联起来
connect(&worker2, SIGNAL(reportProgress(int)), ui->progressBar, SLOT(setValue(int)));
connect(&worker2, SIGNAL(done()), this, SLOT(onCopyFinished()));
最后启动线程即可,运行效果和方法一一致。
//方法二
void Dialog::on_pushButton_2_clicked()
{
qDebug()<<"UI thread:"<<QThread::currentThreadId();
t2.start();
controller2.sig_copy();
}
三、QThread总结
推荐做的:
在QThread子类添加信号。这是绝对安全的,并且也是正确的(发送者的线程依附性没有关系)
不应该做的是:
调用moveToThread(this)函数
指定连接类型:这通常意味着你正在做错误的事情,比如将QThread控制接口与业务逻辑混杂在了一起(而这应该放在该线程的一个独立对象中)
在QThread子类添加槽函数:这意味着它们将在错误的线程被调用,也就是QThread对象所在线程,而不是QThread对象管理的线程。这又需要你指定连接类型或者调用moveToThread(this)函数
使用QThread::terminate()函数
不能做的是:
在线程还在运行时退出程序。使用QThread::wait()函数等待线程结束
在QThread对象所管理的线程仍在运行时就销毁该对象。如果你需要某种“自行销毁”的操作,你可以把finished()信号同deleteLater()槽连接起来
【领QT开发教程学习资料,点击下方链接莬费领取↓↓,先码住不迷路~】
点击这里:「链接」
猜你喜欢
- 2024-10-24 QT(17)- QNetworkAccessManager qnetworkinterface.allinterfaces
- 2024-10-24 从零开始学Qt(86):TCP服务器端程序设计
- 2024-10-24 Qt Core学习日记——第九天QObjectData
- 2024-10-24 Qt智能指针--QSharedPointer qt智能指针.get和.data函数后计数会加吗
- 2024-10-24 QT(11)- QThread qt ui thread work thread
- 2024-10-24 Qt QVariant的用法 qt基本语法
- 2024-10-24 Qt5中QOverload的用法 qt5coredll
- 2024-10-24 Qt多线程编程之QThread qt中的多线程
- 2024-10-24 Qt QModbusReply类 qty是什么单位的缩写
- 2024-10-24 Qt Core学习日记——第十一天QObject(下)
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- oraclesql优化 (66)
- 类的加载机制 (75)
- feignclient (62)
- 一致性hash算法 (71)
- dockfile (66)
- 锁机制 (57)
- javaresponse (60)
- 查看hive版本 (59)
- phpworkerman (57)
- spark算子 (58)
- vue双向绑定的原理 (68)
- springbootget请求 (58)
- docker网络三种模式 (67)
- spring控制反转 (71)
- data:image/jpeg (69)
- base64 (69)
- java分页 (64)
- kibanadocker (60)
- qabstracttablemodel (62)
- java生成pdf文件 (69)
- deletelater (62)
- com.aspose.words (58)
- android.mk (62)
- qopengl (73)
- epoch_millis (61)
本文暂时没有评论,来添加一个吧(●'◡'●)