> 文档中心 > QRunnable线程、QThreadPool(线程池)的使用(含源码+注释)

QRunnable线程、QThreadPool(线程池)的使用(含源码+注释)


一、QRunnable线程、QThreadPool使用示例图

下图为线程池+QRunnable线程的运行示例图;在运行时,当正在运行的线程数到达限定时,后面添加的线程将暂存,当运行的线程运行完成时,或者改变最大线程数,暂存的线程才会启动,源码在本文第三节(源码含详细注释)。
在这里插入图片描述

二、QRunnable和QThreadPool(个人理解)

2.1 QRunnable

使用QRunnable和继承QThread实现的使用方法类似,自定义类继承QRunnable(但是该类不能使用信号槽通信了),并且定必须实现run函数(要做的事情都写在里面)。

2.2 QThreadPool(线程池)

该类是用于继承QRunnable类线程的使用,并且线程池还会对其接收的线程进行管理,如启动,释放等;并且在创建线程池后最好设置线程池最大线程容量,方便管理。

三、源码

3.1 CRunnable定义类

CRunnable.h

#ifndef CRUNNABLE_H#define CRUNNABLE_H#include #include class CRunnable : public QRunnable{public:    explicit CRunnable();    void run();private:    static int  m_sCount;   //定义一个计数值,当新线程创建时就自加(姑且称为线程count)    int  m_number;   //定义一个分辨值,存储当前线程创建时的m_sCount值(姑且称为线程num)};#endif // CRUNNABLE_H

CRunnable.cpp

#include "CRunnable.h"#include #include int CRunnable::m_sCount = 0;CRunnable::CRunnable(){    m_number = ++m_sCount;  //创建时将计数值加一,并将其赋给分辨值}void CRunnable::run(){    //循环5次    for(int index = 0; index != 5; ++index)    { //输出当前线程的num、线程静态变量count以及线程id qDebug() << QString("当前线程num为:%1  线程count为:%2")      .arg(m_number).arg(m_sCount) << QThread::currentThreadId(); QThread::usleep(900000);     //使线程睡眠一段时间(单位:微秒),作用为减缓输出速度    }}

3.2 CMainWindow调用类

CMainWindow.h

#ifndef CMAINWINDOW_H#define CMAINWINDOW_H#include #include "CRunnable.h"#include namespace Ui {class CMainWindow;}class CMainWindow : public QMainWindow{    Q_OBJECTpublic:    explicit CMainWindow(QWidget *parent = 0);    ~CMainWindow();private slots:    void on_startBtn_clicked();    private:    Ui::CMainWindow *   ui;    QThreadPool *m_threadPool;  //创建一个线程池指针};#endif // CMAINWINDOW_H

CMainWindow.cpp

#include "CMainWindow.h"#include "ui_CMainWindow.h"#include CMainWindow::CMainWindow(QWidget *parent) :    QMainWindow(parent),    ui(new Ui::CMainWindow){    ui->setupUi(this);    //new出线程池对象    m_threadPool = new QThreadPool;    m_threadPool->setMaxThreadCount(3); //设置线程池可容纳线程最大为3个}CMainWindow::~CMainWindow(){    m_threadPool->clear();  //清空线程池    delete m_threadPool;    //线程池释放时会将其中运行的线程一起释放    delete ui;}void CMainWindow::on_startBtn_clicked(){    //这里会自带将添加的CRunnable启动(如同QThread线程调用start的效果),并且线程激活数将会+1    m_threadPool->start(new CRunnable);    //输出线程激活数    qDebug() << "当前正在运行的线程有:" <<m_threadPool->activeThreadCount() << "个";}

总结

线程池使用时传入继承于的QRunnable类对象(并启动该线程对象),并且线程池会自主释放在其中的线程(提高程序性能),还能实现并发,提高效率;不过不能使用信号槽进行通信,需要使用QMetaObject::invokeMethod进行通信。

相关文档

启动QThread线程的两种方法(含源码+注释)
Qt互斥锁(QMutex)、条件变量(QWaitCondition)讲解+QMutex实现多线程循环输出ABC(含源码+注释)
Qt互斥锁(QMutex)的使用、QMutexLocker的使用(含源码+注释)
QSemaphore的使用+QSemaphore实现循环输出ABC(含源码+注释)

友情提示——哪里看不懂可私哦,让我们一起互相进步吧
(创作不易,请留下一个免费的赞叭 谢谢 ^o^/)

注:文章为作者编程过程中所遇到的问题和总结,内容仅供参考,若有错误欢迎指出。
注:如有侵权,请联系作者删除