Qt QThreadPool线程池

news2024/12/24 2:16:50

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 个线程在执行任务。其他的任务会在线程池中的线程变为可用时被执行。

#include "widget.h"
#include "ui_widget.h"
#include <QRunnable>
#include <QThreadPool>
#include <QDebug>
#include <QMutex>
#include <QList>

QList<int> g_list;
QMutex g_mutex;

class MyRunnable : public QRunnable
{
public:
    void run() override
    {
        while(true)
        {
            g_mutex.lock();
            if(g_list.size() == 0)
            {
                g_mutex.unlock();
                break;
            }
            qDebug() << "Task running in thread:" << QThread::currentThread() << "deal num "<<g_list.first();
            g_list.pop_front();
            g_mutex.unlock();
        }
        qDebug() << "Task running in thread:" << QThread::currentThread() << "finished ";
    }
};

Widget::Widget(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);

    for(int i=0;i<20;i++)
    {
        g_list.append(i);
    }

    QThreadPool::globalInstance()->setMaxThreadCount(4);

    for (int i = 0; i < 4; ++i)
    {
        MyRunnable *r = new MyRunnable();
        r->setAutoDelete(true);
        QThreadPool::globalInstance()->start(r);

    }
}

Widget::~Widget()
{
    delete ui;
}

运行结果：