当前位置:   article > 正文

Qt QThreadPool线程池

Qt QThreadPool线程池

1.简介

QThreadPool类管理一个QThread集合。
QThreadPool管理和重新设计单个QThread对象,以帮助降低使用线程的程序中的线程创建成本。每个Qt应用程序都有一个全局QThreadPool对象,可以通过调用globalInstance来访问该对象。
要使用其中一个QThreadPool线程,请子类化QRunnable并实现run虚拟函数。然后创建该类的一个对象,并将其传递给QThreadPool::start。

主要特点:

  • 线程复用:线程池中的线程可以重复使用,减少了线程创建和销毁的开销。
  • 资源管理:线程池可以帮助管理线程的生命周期,包括线程的创建、销毁和线程数的控制。
  • 任务队列:线程池通常与一个任务队列一起使用,允许你将任务添加到队列中,由线程池中的线程执行。

2.常用方法

  • globalInstance(): 获取全局的 QThreadPool实例。
  • maxThreadCount(): 获取线程池中最大线程数。
  • setMaxThreadCount(int): 设置线程池中最大线程数。
  • activeThreadCount(): 获取当前活跃的线程数。
  • expiryTimeout(): 获取线程的最长存活时间。
  • setExpiryTimeout(int): 设置线程的最长存活时间。
  • start(QRunnable *): 将一个 QRunnable 对象添加到线程池的任务队列中,并在线程池中的一个线程上执行它。
  • tryStart(QRunnable *): 尝试立即在一个空闲线程上执行 QRunnable 对象,如果失败则返回 false
  • waitForDone(int): 阻塞调用线程,直到所有任务执行完毕或超时。
  • clear(): 清空任务队列,停止所有正在执行的任务。
  • releaseThread(): 通知线程池当前线程已经完成了一个任务,可以重新被使用。

3.示例

我们创建了一个简单的 QRunnable 子类 MyRunnable,并在主函数中使用了 QThreadPool 来执行 4 个任务。我们设置了线程池的最大线程数为 4,这意味着同时最多有 4 个线程在执行任务。其他的任务会在线程池中的线程变为可用时被执行。

  1. #include "widget.h"
  2. #include "ui_widget.h"
  3. #include <QRunnable>
  4. #include <QThreadPool>
  5. #include <QDebug>
  6. #include <QMutex>
  7. #include <QList>
  8. QList<int> g_list;
  9. QMutex g_mutex;
  10. class MyRunnable : public QRunnable
  11. {
  12. public:
  13. void run() override
  14. {
  15. while(true)
  16. {
  17. g_mutex.lock();
  18. if(g_list.size() == 0)
  19. {
  20. g_mutex.unlock();
  21. break;
  22. }
  23. qDebug() << "Task running in thread:" << QThread::currentThread() << "deal num "<<g_list.first();
  24. g_list.pop_front();
  25. g_mutex.unlock();
  26. }
  27. qDebug() << "Task running in thread:" << QThread::currentThread() << "finished ";
  28. }
  29. };
  30. Widget::Widget(QWidget *parent) :
  31. QWidget(parent),
  32. ui(new Ui::Widget)
  33. {
  34. ui->setupUi(this);
  35. for(int i=0;i<20;i++)
  36. {
  37. g_list.append(i);
  38. }
  39. QThreadPool::globalInstance()->setMaxThreadCount(4);
  40. for (int i = 0; i < 4; ++i)
  41. {
  42. MyRunnable *r = new MyRunnable();
  43. r->setAutoDelete(true);
  44. QThreadPool::globalInstance()->start(r);
  45. }
  46. }
  47. Widget::~Widget()
  48. {
  49. delete ui;
  50. }

运行结果:

4.更多推荐

libVLC 专栏介绍-CSDN博客

Qt+FFmpeg+opengl从零制作视频播放器-1.项目介绍_qt opengl视频播放器-CSDN博客

QCharts -1.概述-CSDN博客

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/凡人多烦事01/article/detail/524980
推荐阅读
相关标签
  

闽ICP备14008679号