Qt 中的线程池QRunnable和QThreadPool

server/2025/2/24 23:59:09/

Qt 中的线程池QRunnable和QThreadPool

一、QThreadPool类介绍

QThreadPool 是 Qt 框架中用于管理线程池的类,它提供了一种高效的方式来管理和复用线程,避免频繁创建和销毁线程带来的开销。

1. 基本概念

QThreadPool 是一个全局的线程池,它维护了一组线程,并将任务分配给这些线程执行。线程池中的线程数量可以通过设置最大线程数来控制。当线程池中的线程被占用时,新任务会被排队等待执行。

2. 创建和使用线程池

Qt 提供了一个全局线程池 QThreadPool::globalInstance(),可以直接使用,也可以创建自己的线程池实例。

全局线程池的使用:

// 获取全局线程池
QThreadPool *threadPool = QThreadPool::globalInstance();
// 设置最大线程数(可选)
threadPool->setMaxThreadCount(4);

自定义线程池的使用:

QThreadPool *myThreadPool = new QThreadPool();
myThreadPool->setMaxThreadCount(8); // 设置最大线程数

3. 关键方法

以下是 QThreadPool 的一些常用方法:

(1) 设置线程池的最大线程数
void QThreadPool::setMaxThreadCount(int maxThreadCount);

用于设置线程池中允许的最大线程数。默认值通常是系统核心数的两倍。

(2) 启动任务
void QThreadPool::start(QRunnable *runnable);

将一个 QRunnable 对象提交到线程池中执行。

(3) 等待所有任务完成
void QThreadPool::waitForDone();

阻塞当前线程,直到线程池中的所有任务都完成。

(4) 获取全局线程池
static QThreadPool *QThreadPool::globalInstance();

返回全局线程池实例,通常用于共享程线池。

4. 注意事项

  1. 线程安全QThreadPool 是线程安全的,可以在多个线程中同时调用其方法。
  2. 任务的生命周期:任务对象(QRunnable 的子类)通常由线程池管理,任务完成后会被自动删除。如果需要手动管理任务对象的生命周期,可以在任务类中重写 autoDelete() 方法。
  3. 任务队列:当线程池中的线程被占用时,新任务会被放入队列中等待执行。
  4. 线程池的销毁:当线程池被销毁时,所有未完成的任务会被取消,线程池中的线程也会被销毁。

二、QRunnable类介绍

QRunnable 是 Qt 框架中用于表示可运行任务的类,它是线程池(QThreadPool)中任务的接口。通过继承 QRunnable 并重写其 run() 方法,可以创建一个可以在单独线程中执行的任务。QRunnable 是 Qt 实现线程池任务调度的核心机制之一。

1. QRunnable 的作用

QRunnable 是一个抽象类,用于表示一个可以被线程执行的任务。它的主要目的是将任务封装为一个对象,然后通过线程池(QThreadPool)或其他线程管理机制来执行这些任务。QRunnable 的设计使得任务的创建和执行解耦,从而提高了代码的可维护性和可扩展性。

2. QRunnable 的基本用法

要使用 QRunnable,通常需要执行以下步骤:

1继承 QRunnable:创建一个继承自 QRunnable 的类。

2.重写 run() 方法:在 run() 方法中实现任务的逻辑。

3.提交任务到线程池:通过 QThreadPoolstart() 方法将任务提交到线程池中执行。

3. QRunnable 的关键特性

(1) 自动删除

QRunnable 提供了一个 autoDelete() 方法,用于控制任务对象在执行完成后是否自动删除。默认情况下,autoDelete() 返回 true,表示任务对象会在执行完成后自动删除。如果需要手动管理任务对象的生命周期,可以在任务类中重写 autoDelete() 方法。

bool QRunnable::autoDelete() const;
(2) 设置优先级

QRunnable 允许设置任务的优先级,优先级高的任务会优先执行。

void QRunnable::setAutoDelete(bool autoDelete);
void QRunnable::setPriority(QThread::Priority priority);
(3) 线程安全

QRunnable 是线程安全的,可以在多个线程中同时创建和提交任务。

4. QRunnable 的应用场景

QRunnable 适用于以下场景:

1.并发任务:需要在多个线程中并发执行任务时,QRunnable 是一个很好的选择。

2.线程池管理:通过 QThreadPoolQRunnable,可以高效地管理线程池中的任务,避免频繁创建和销毁线程。

3.简化线程管理QRunnable 将任务封装为对象,使得任务的创建和执行更加清晰和易于管理。

5. QRunnable 和 QThread 的区别

虽然 QRunnableQThread 都可以用于多线程编程,但它们的用途和设计目标有所不同:

  • QThread
    • 是一个完整的线程类,提供了对线程生命周期的精细控制。
    • 适用于需要长期运行的线程,或者需要手动管理线程生命周期的场景。
    • 使用起来相对复杂,需要手动启动和停止线程。
  • QRunnable
    • 是一个任务类,用于表示一个可以在单独线程中执行的任务。
    • 通常与 QThreadPool 配合使用,适用于短时间任务的并发执行。
    • 使用起来相对简单,任务完成后会自动删除。

三、使用示例

下面通过一个代码示例来讲述如何使用:

#include <QCoreApplication>
#include <QThreadPool>
#include <QRunnable>
#include <QThread>
#include <QDebug>class QMyTask:public QRunnable
{
public:QMyTask(int nID){m_nID = nID;}~QMyTask(){};virtual void run() override{qDebug() << "Task"<< m_nID << "Is Run On Thread" << QThread::currentThreadId();QThread::sleep(2); // 模拟耗时任务qDebug() << "Task" << m_nID << "finished";}private:int m_nID;
};int main(int argc, char *argv[])
{QCoreApplication a(argc, argv);QThreadPool* pThreadPool = QThreadPool::globalInstance();pThreadPool->setMaxThreadCount(4);for(int i=0;i<10;i++){QMyTask* pTask = new QMyTask(i);pThreadPool->start(pTask);}pThreadPool->waitForDone();qDebug() << "All tasks are done.";return a.exec();
}

代码运行结果:

微信截图_20250223112303

四、总结

1.QThreadPool 提供了一种简单而高效的方式来管理线程,特别适合处理大量短时间任务的场景。通过合理设置线程池的大小和任务的管理方式,可以显著提高程序的性能和响应速度。

2.QRunnable 是 Qt 中用于表示可运行任务的类,它通过线程池(QThreadPool)实现任务的并发执行。通过继承 QRunnable 并重写 run() 方法,可以轻松创建和管理任务。QRunnable 的设计使得任务的创建和执行解耦,提高了代码的可维护性和可扩展性。在需要并发执行短时间任务时,QRunnable 是一个非常高效的选择。

参考文章:

1.QT线程池的使用:QThreadPool类和QRunnable类


http://www.ppmy.cn/server/170426.html

相关文章

解决github验证问题

The authenticity of host ‘github.com’ can’t be established.ED25519 key fingerprint is SHA256 首先&#xff0c;生成 SSH key&#xff1a; ssh-keygen -t ed25519 -C "your_emailexample.com"启动 ssh-agent&#xff1a; eval "$(ssh-agent -s)"…

DevOps自动化部署详解:从理念到实践

在软件开发日益快速迭代的今天&#xff0c;如何以高效、稳定且可重复的方式将代码变更从开发环境自动部署到生产环境成为企业竞争的重要因素。DevOps 正是在这一背景下应运而生&#xff0c;它打破开发、测试、运维之间的壁垒&#xff0c;通过自动化工具和流程&#xff0c;实现持…

基于ffmpeg+openGL ES实现的视频编辑工具-添加转场(九)

在视频编辑的广阔领域中,转场效果无疑是提升视频流畅性与观赏性的关键要素。巧妙运用转场,能够让不同视频片段之间的衔接更为自然,同时赋予视频独特的创意魅力。本文将深入探讨如何借助 ffmpeg 和 openGL ES 技术,在视频编辑工具中实现丰富多样的转场效果。 一、转场技术原…

Spring BOOT 启动参数

Spring BOOT 启动参数 在Java Web的开发完成后&#xff0c;以前我们都会打包成war文件&#xff0c;然后放大web容器&#xff0c;比如tomcat、jetty这样的容器。现在基于SpringBoot开发的项目&#xff0c;我们直接打包成jar文件&#xff0c;基于内嵌的tomcat来实现一样的效果。…

高级应用:使用 p-retry 处理 Node.js 中的重试逻辑

在现代的分布式系统和网络应用中,失败是不可避免的。无论是网络请求、数据库操作还是外部 API 调用,都可能因为各种原因(如网络波动、服务不可用、资源限制等)而失败。为了增强应用的健壮性,我们通常需要实现重试逻辑。p-retry 是一个强大的 Node.js 库,专门用于处理异步…

【Bluedroid】AVRCP 连接源码分析(三)

接着上一篇【Bluedroid】AVRCP 连接源码分析(一)-CSDN博客,继续AVRCP连接的源码分析。 AVRC_OpenBrowse /packages/modules/Bluetooth/system/stack/avrc/avrc_api.cc /******************************************************************************** Function …

【网络编程】基于 TCP协议 的服务器-客户端通信模型的加密传输、多线程并发服务器

基于上一篇中 网络编程基础:TCP/UDP 协议 实现了基于 TCP 协议的网络通信模型。基于此之上,我们继续介绍 加密传输、用多线程实现客户端程序与网络调试助手进行双向通信(多线程并发服务器)。 这是一个基于 OpenSSL 的 TLS(SSL)加密传输的 TCP 服务器-客户端 通信示例。这…

基于MFC实现的键盘电子乐器演奏程序

基于MFC实现的键盘电子乐器演奏程序设计 1.项目简介 需要连接西电微机原理实验室提供的 QTH9054 微机试验箱&#xff0c;使用其蜂鸣器发声&#xff0c;若不连接&#xff0c;程序会直接播放 mp3 文件模拟钢琴声。 请在 release 处下载编译好的 exe 文件运行&#xff0c;如需计…