点击蓝字 关注咱们web
QThreadPool与QRunnable
线程的建立及销毁须要与系统交互，会产生很大的开销。若须要频繁的建立线程建议使用线程池，有线程池维护必定数量的线程，当须要进行多线程运算时将运算函数传递给线程池便可。线程池会根据可用线程进行任务安排。编程
QThreadPool
此类为Qt提供的线程池函数，使用此类只须要配置线程池的最大线程数量、线程长时间不使用的过时时间等参数，不须要进行QThread相关的操做。微信
此类有两种使用方式：全局线程池和局部线程池。多线程
Public Function
int activeThreadCount() const //当前的活动线程数量
void clear()//清除全部当前排队但未开始运行的任务
int expiryTimeout() const//线程长时间未使用将会自动退出节约资源，此函数返回等待时间
int maxThreadCount() const//线程池可维护的最大线程数量
void releaseThread()//释放被保留的线程
void reserveThread()//保留线程，此线程将不会占用最大线程数量，从而可能会引发当前活动线程数量大于最大线程数量的状况
void setExpiryTimeout(int expiryTimeout)//设置线程回收的等待时间
void setMaxThreadCount(int maxThreadCount)//设置最大线程数量
void setStackSize(uint stackSize)//此属性包含线程池工做线程的堆栈大小。
uint stackSize() const//堆大小
void start(QRunnable *runnable, int priority = 0)//加入一个运算到队列，注意start不必定马上启动，只是插入到队列，排到了才会开始运行。须要传入QRunnable ，后续介绍
bool tryStart(QRunnable *runnable)//尝试启动一个
bool tryTake(QRunnable *runnable)//删除队列中的一个QRunnable，若当前QRunnable 未启动则返回成功，正在运行则返回失败
bool waitForDone(int?<i>msecs</i>?=?-1)//等待全部线程运行结束并退出，参数为等待时间-1表示一直等待到最后一个线程退出
全局线程池
QThreadPool提供了一个静态函数，globalInstance()，使用此方法可获取一个当前进程的全局线程池，可在多个类中共同使用一个线程池。app
局部线程池
和常规类的使用相同，能够经过QThreadPool pool;的方式创建一个局部线程池，并由当前类维护，可保证此线程池仅供当前类应用编辑器
QRunnable类
QRunnable类在Qt中是全部可运行对象的基类，表明了由run（）函数表示的一个任务或一段要执行的代码。咱们通常使用该类和QThreadPool来在另外一个独立的线程中执行该代码。而且，若是QRunnable对象的autoDelete()设为true的话，QThreadPool会在run（）运行结束后自动删除该对象。函数
QRunnable有run、autodelete、setautodelete这三个关键函数。学习
重写run函数flex
protected:
void run();
QRunable与线程池例子
程序演示：ui
建立线程池,定义线程数量为15，在里面取出两个线程去进行业务逻辑处理,这里的逻辑处理就是打印0~10
建立一个MyRUnable类,继承QObject和QRunnable
myrunable.h:
#ifndef MYRUNABLE_H
#define MYRUNABLE_H
#include <QObject>
#include <QRunnable>
#include <QDebug>
#include <QThread>
class MyRunable : public QObject, public QRunnable
{
Q_OBJECT
public:
explicit MyRunable(QObject *parent = nullptr);
~MyRunable();
protected:
void run();
};
#endif // MYRUNABLE_H
myrunable.c
#include "myrunable.h"
MyRunable::MyRunable(QObject *parent) : QObject(parent)
{
}
MyRunable::~MyRunable()
{
qDebug()<<"delete Task";
}
void MyRunable::run()
{
int i = 10;
while(i--)
{
qDebug() << "线程id："<< QThread::currentThreadId()<< QString(":剩余%1").arg(i);
QThread::sleep(1);
}
}
main.c
#include <QCoreApplication>
#include <QDebug>
#include <QThread>
#include <QThreadPool>
#include"myrunable.h"
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
qDebug() << "main thread id: " << QThread::currentThreadId();
QThreadPool::globalInstance()->setMaxThreadCount(15); //设置线程池最大线程数量
MyRunable* task = new MyRunable();
task->setAutoDelete(true); //autoDelete属性默认为true QThreadPool会在run（）函数运行结束后，自动删除了MyTask对象
QThreadPool::globalInstance()->start(task); //任务放进线程池
QThread::sleep(1);
MyRunable* task1 = new MyRunable();
task1->setAutoDelete(true);
QThreadPool::globalInstance()->start(task1);
QThreadPool::globalInstance()->waitForDone(); //等待任务结束
qDebug() << "end";
return a.exec();
}
关键字【线程池】
End
本文分享自微信公众号 - 编程学习基地（LearnBase）。
若有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一块儿分享。