Qt中多线程使用案列

2023-12-21 22:28
文章标签 使用 qt 多线程 案列

本文主要是介绍Qt中多线程使用案列，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Qt中多线程下载大文件

#pragma once#include <QWidget>
#include <QPushButton>
#include "ThreadPool.h"
#include <QProgressBar>
#include <QLabel>
#include <QHBoxLayout>
#include <QVBoxLayout>
class MainWindow : public QWidget
{Q_OBJECTpublic:MainWindow(QWidget *parent = Q_NULLPTR);private:void initUI();void initConnect();private:QPushButton*  m_dlBtn;DownLoad::ThreadPool  threadPool;QMap<QString ,std::pair<QLabel*,QProgressBar*> > controlMap;};
#include "MainWindow.h"#include "Task.h"
#include "ThreadPool.h"
MainWindow::MainWindow(QWidget *parent): QWidget(parent)
{initUI();initConnect();
}void MainWindow::initUI()
{m_dlBtn = new QPushButton(this);m_dlBtn->setText(QString("DownLoad"));QVBoxLayout*  layout = new QVBoxLayout();layout->setSpacing(10);layout->setContentsMargins(10, 10, 10, 10);layout->addWidget(m_dlBtn);for (int i = 0; i < 10; i++){DownLoad::Task* task = new DownLoad::Task("http://mirrors.tuna.tsinghua.edu.cn/archlinux/iso/2023.12.01/archlinux-2023.12.01-x86_64.iso", QString("C:/Users/gd09861-hlw/Desktop/11111/archlinux-2023.12.01-x86_64_%1.iso").arg(i), DownLoad::Task::WorkModel::DOWNLOAD);threadPool.push(task);QLabel *label = new QLabel(this);label->setText(QString("%1").arg(i));QProgressBar *progressBar = new QProgressBar(this);controlMap.insert(task->id(), std::make_pair(label, progressBar));QHBoxLayout *hLayout = new QHBoxLayout;hLayout->addWidget(label);hLayout->addWidget(progressBar);layout->addLayout(hLayout);}this->setLayout(layout);
}void MainWindow::initConnect()
{connect(m_dlBtn, &QPushButton::clicked, [&]() {threadPool.startAll();});connect(&threadPool, &DownLoad::ThreadPool::sigUpdateTaskProgress, this, [&](QString id, qint64 bytesR, qint64 bytesT) {controlMap[id].second->setValue((bytesR*100.0f) / (bytesT*1.0f));});connect(&threadPool, &DownLoad::ThreadPool::sigUpdateTaskState, this, [&](QString id,DownLoad::Task::State state) {switch (state){case DownLoad::Task::Start:{controlMap[id].second->setValue(0);}break;case DownLoad::Task::Stop: {controlMap[id].first->setText("Stop");}break;case DownLoad::Task::Finish:controlMap[id].first->setText("Finish");break;case DownLoad::Task::Error:controlMap[id].first->setText("error");break;default:break;}});
}
#ifndef  __TASK_QUEUE_H__
#define  __TASK_QUEUE_H__#include <QObject>
#include <QString>
#include "Task.h"
#include <QQueue>
#include <QMutex>
namespace DownLoad {#define  DEFAULT_THREAD_MAX_COUNT  3class ThreadPool :public QObject{Q_OBJECTpublic:ThreadPool();~ThreadPool();void init();void  push(Task *task);Task* pop();void startAll();void slotUpdateTaskState(QString id, Task::State  state);signals :void sigUpdateTaskProgress(QString id, qint64 bytesReceived, qint64 bytesTotal);void sigUpdateTaskState(QString id, Task::State  state);private:QQueue<Task*>  m_tasks;QList<QThread*>  m_threads;};
};
#endif

#include "ThreadPool.h"
#include <QMutexLocker>
#include <QThread>
#include "Task.h"
DownLoad::ThreadPool::ThreadPool()
{init();
}DownLoad::ThreadPool::~ThreadPool()
{}void DownLoad::ThreadPool::init()
{for (int i = 0; i < DEFAULT_THREAD_MAX_COUNT; i++) {QThread  *thread = new QThread();m_threads.push_back(thread);}
}void DownLoad::ThreadPool::push(Task *task)
{m_tasks.enqueue(task);
}DownLoad::Task* DownLoad::ThreadPool::pop()
{return m_tasks.dequeue();
}void DownLoad::ThreadPool::startAll()
{if (m_threads.isEmpty()) {return;}for (int i = 0; i < m_threads.count(); i++){QThread *  thread = m_threads.at(i);if (thread->isRunning()) {continue;}if (m_tasks.isEmpty()) {return;}Task* task = pop();task->moveToThread(thread);connect(task, &Task::sigUpdateProgress, this, &ThreadPool::sigUpdateTaskProgress, Qt::QueuedConnection);connect(task, &Task::sigUpdateState, this, &ThreadPool::slotUpdateTaskState, Qt::QueuedConnection);connect(thread, &QThread::started, task, &Task::slotDoWork,Qt::QueuedConnection);connect(thread, &QThread::finished, task, &Task::deleteLater);thread->start();}
}void DownLoad::ThreadPool::slotUpdateTaskState(QString id, Task::State  state)
{emit  sigUpdateTaskState(id, state);if (state == DownLoad::Task::Finish || state == DownLoad::Task::Error||state==DownLoad::Task::Stop) {startAll();}
}
#ifndef  __TASK_H__
#define  __TASK_H__#include <QObject>
#include <QNetworkRequest>
#include <QNetworkReply>
#include <QNetworkAccessManager>
#include <QSharedPointer>
#include <QUrl>
#include <QString>
#include <QEventLoop>
#include <QMetaType>
namespace  DownLoad {
#define  DOWNLOAD_FILE_SUFFIX  ".tmp"class Task :public QObject{Q_OBJECTpublic:enum WorkModel{UPLOAD,DOWNLOAD,};enum State{Start,Stop,Finish,Error,};QString  id();Task(const QString &strUrl, const QString &filePath, const WorkModel& workModel);~Task();void setSupportBreakPoint(bool isSupport);QString lastError();signals:void sigUpdateState(QString id,State  state);void sigUpdateProgress(QString id,qint64 bytesReceived, qint64 bytesTotal);public slots:void slotDoWork();void slotStopWork();void slotCancelWork();protected:void removeTmpFile(const QString &filePath);void slotUpdateProgress(qint64 bytesReceived, qint64 bytesTotal);void slotWriteFile();void slotFinish();void slotError(QNetworkReply::NetworkError code);protected:void doDownWork();void doUploadWork();private:QNetworkReply*				 m_reply = nullptr;QNetworkRequest				 m_request;QNetworkAccessManager		 m_manager;QUrl m_url;QString m_filePath = "";WorkModel  m_workModel = UPLOAD;QSharedPointer<QEventLoop>  m_loop;bool m_bSupportBPoint = false;qint64  m_bytesReceived;qint64  m_bytesTotal;qint64  m_bytesCurrentReceived;QString m_error = "";QString m_id = "";};};
Q_DECLARE_METATYPE(DownLoad::Task::State);#endif     //__TASK_H__

#include "Task.h"
#include <QFileInfo>
#include <QUuid>
#include <QDebug>
#include <QThread>
#include <QDir>QString DownLoad::Task::id()
{return m_id;
}DownLoad::Task::Task(const QString &strUrl, const QString &filePath, const WorkModel& workModel):QObject(nullptr), m_url(strUrl), m_filePath(filePath), m_workModel(workModel),m_bytesTotal(0),m_bytesReceived(0),m_bytesCurrentReceived(0),m_bSupportBPoint(false),m_id(QUuid::createUuid().toString())
{}DownLoad::Task::~Task()
{if (m_reply) {m_reply->deleteLater();}}void DownLoad::Task::setSupportBreakPoint(bool isSupport)
{m_bSupportBPoint = isSupport;
}QString DownLoad::Task::lastError()
{return m_error;
}void DownLoad::Task::slotDoWork()
{qDebug() << "UUID:" << m_id << "TID:" << QThread::currentThreadId()<<"\t"<<m_filePath;if (m_url.isEmpty() || m_filePath.isEmpty()) {return;}switch (m_workModel){case DownLoad::Task::UPLOAD:doUploadWork();break;case DownLoad::Task::DOWNLOAD:doDownWork();break;default:break;}
}void DownLoad::Task::slotStopWork()
{m_bytesCurrentReceived += m_bytesReceived;if (m_reply) {disconnect(m_reply, 0, this, 0);m_reply->abort();m_reply->deleteLater();m_reply = nullptr;this->thread()->exit();emit  sigUpdateState(m_id,State::Stop);}
}void DownLoad::Task::slotCancelWork()
{slotStopWork();m_bytesCurrentReceived = 0;m_bytesReceived = 0;m_bytesTotal = 0;removeTmpFile(m_filePath + DOWNLOAD_FILE_SUFFIX);
}void DownLoad::Task::removeTmpFile(const QString &filePath)
{QFileInfo fileInfo(filePath);if (fileInfo.exists()) {QFile::remove(filePath);}
}void DownLoad::Task::slotUpdateProgress(qint64 bytesReceived, qint64 bytesTotal)
{m_bytesReceived = bytesReceived;m_bytesTotal = bytesTotal;emit  sigUpdateProgress(m_id,m_bytesReceived + m_bytesCurrentReceived, m_bytesTotal + m_bytesCurrentReceived);
}void DownLoad::Task::slotWriteFile()
{QFile file(m_filePath + DOWNLOAD_FILE_SUFFIX);QDir dir=QFileInfo(m_filePath + DOWNLOAD_FILE_SUFFIX).absoluteDir();if (!dir.exists()) {dir.mkpath(dir.absolutePath());}if (file.open(QIODevice::WriteOnly | QIODevice::Append)) {file.write(m_reply->readAll());}file.close();
}void DownLoad::Task::slotFinish()
{QVariant  code = m_reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);qDebug() << "Error Code:" << code.toInt();if (m_reply->error() == QNetworkReply::NoError) {QFileInfo fileInfo(m_filePath + DOWNLOAD_FILE_SUFFIX);if (fileInfo.exists()) {QFile::rename(m_filePath+DOWNLOAD_FILE_SUFFIX,m_filePath);this->thread()->exit();emit sigUpdateState(m_id, State::Finish);}}else { m_error = m_reply->errorString();this->thread()->exit();emit sigUpdateState(m_id, State::Error);}
}void DownLoad::Task::slotError(QNetworkReply::NetworkError code)
{if (code == QNetworkReply::NoError)return;slotStopWork();removeTmpFile(m_filePath + DOWNLOAD_FILE_SUFFIX);this->thread()->exit();emit	 sigUpdateState(m_id, State::Error);m_error = m_reply->errorString();}void DownLoad::Task::doDownWork()
{if (m_bytesCurrentReceived <= 0) {removeTmpFile(m_filePath + DOWNLOAD_FILE_SUFFIX);}QFileInfo  fileInfo(m_filePath + DOWNLOAD_FILE_SUFFIX);if (fileInfo.exists()) {m_bytesCurrentReceived = fileInfo.size();}QString strUrl = m_url.toString();m_request.setUrl(strUrl);if (m_bSupportBPoint) {QString strRange = QString("bytes=%1-").arg(m_bytesCurrentReceived);m_request.setRawHeader("Range", strRange.toLatin1());}m_reply = m_manager.get(m_request);connect(m_reply, &QNetworkReply::downloadProgress, this, &Task::slotUpdateProgress);connect(m_reply, &QNetworkReply::readyRead, this, &Task::slotWriteFile);connect(m_reply, &QNetworkReply::finished, this, &Task::slotFinish);connect(m_reply, SIGNAL(error(QNetworkReply::NetworkError code)), this,SLOT(slotError(QNetworkReply::NetworkError code)));
}void DownLoad::Task::doUploadWork()
{}

上处代码运行可以看出，QThread 中,每次调用start() 时 ，都会改变线程ID 在这里插入图片描述
因此，QT 的线程开启就是在创建线程，只不过其中含有事件循环机制。另外对于自定义类型，必须指定队列连接。
运行后在这里插入图片描述

这篇关于Qt中多线程使用案列的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/521689。

相关文章

gitlab安装及邮箱配置和常用使用方式

gitlab安装及邮箱配置和常用使用方式

《gitlab安装及邮箱配置和常用使用方式》：本文主要介绍gitlab安装及邮箱配置和常用使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1.安装GitLab2.配置GitLab邮件服务3.GitLab的账号注册邮箱验证及其分组4.gitlab分支和标签的
阅读更多...
SpringBoot3应用中集成和使用Spring Retry的实践记录

SpringBoot3应用中集成和使用Spring Retry的实践记录

《SpringBoot3应用中集成和使用SpringRetry的实践记录》SpringRetry为SpringBoot3提供重试机制,支持注解和编程式两种方式,可配置重试策略与监听器,适用于临时性故... 目录1. 简介2. 环境准备3. 使用方式3.1 注解方式 基础使用自定义重试策略失败恢复机制注意事项
阅读更多...
nginx启动命令和默认配置文件的使用

nginx启动命令和默认配置文件的使用

《nginx启动命令和默认配置文件的使用》：本文主要介绍nginx启动命令和默认配置文件的使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录常见命令nginx.conf配置文件location匹配规则图片服务器总结常见命令# 默认配置文件启动./nginx
阅读更多...
在Windows上使用qemu安装ubuntu24.04服务器的详细指南

在Windows上使用qemu安装ubuntu24.04服务器的详细指南

《在Windows上使用qemu安装ubuntu24.04服务器的详细指南》本文介绍了在Windows上使用QEMU安装Ubuntu24.04的全流程：安装QEMU、准备ISO镜像、创建虚拟磁盘、配置... 目录1. 安装QEMU环境2. 准备Ubuntu 24.04镜像3. 启动QEMU安装Ubuntu4
阅读更多...
使用Python和OpenCV库实现实时颜色识别系统

使用Python和OpenCV库实现实时颜色识别系统

《使用Python和OpenCV库实现实时颜色识别系统》：本文主要介绍使用Python和OpenCV库实现的实时颜色识别系统,这个系统能够通过摄像头捕捉视频流,并在视频中指定区域内识别主要颜色（红... 目录一、引言二、系统概述三、代码解析1. 导入库2. 颜色识别函数3. 主程序循环四、HSV色彩空间详解
阅读更多...
Windows下C++使用SQLitede的操作过程

Windows下C++使用SQLitede的操作过程

《Windows下C++使用SQLitede的操作过程》本文介绍了Windows下C++使用SQLite的安装配置、CppSQLite库封装优势、核心功能（如数据库连接、事务管理）、跨平台支持及性能优... 目录Windows下C++使用SQLite1、安装2、代码示例CppSQLite：C++轻松操作SQ
阅读更多...
Python常用命令提示符使用方法详解

Python常用命令提示符使用方法详解

《Python常用命令提示符使用方法详解》在学习python的过程中,我们需要用到命令提示符(CMD)进行环境的配置,：本文主要介绍Python常用命令提示符使用方法的相关资料,文中通过代码介绍的... 目录一、python环境基础命令【Windows】1、检查Python是否安装2、 查看Python的安
阅读更多...
Python并行处理实战之如何使用ProcessPoolExecutor加速计算

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

《Python并行处理实战之如何使用ProcessPoolExecutor加速计算》Python提供了多种并行处理的方式,其中concurrent.futures模块的ProcessPoolExecu... 目录简介完整代码示例代码解释1. 导入必要的模块2. 定义处理函数3. 主函数4. 生成数字列表5.
阅读更多...
Python中help()和dir()函数的使用

Python中help()和dir()函数的使用

《Python中help()和dir()函数的使用》我们经常需要查看某个对象（如模块、类、函数等）的属性和方法,Python提供了两个内置函数help()和dir(),它们可以帮助我们快速了解代... 目录1. 引言2. help() 函数2.1 作用2.2 使用方法2.3 示例(1) 查看内置函数的帮助(
阅读更多...
Linux脚本(shell)的使用方式

Linux脚本(shell)的使用方式

《Linux脚本(shell)的使用方式》：本文主要介绍Linux脚本(shell)的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录概述语法详解数学运算表达式Shell变量变量分类环境变量Shell内部变量自定义变量：定义、赋值自定义变量：引用、修改、删
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2