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