说明
QThread是qt中的一个线程类。目前我了解到的共有两种用法,一种是作为普通的线程,就像c++标准库中的std::thread一样,另一种就是作为信号槽的容器,负责调用qt的事件循环。
作为普通线程
重载QThread::run()这个虚函数,在里面运行自己的循环就可以了。
class WorkerThread : public QThread
{
Q_OBJECT
void run() override {
QString result;
/* ... here is the expensive or blocking operation ... */
emit resultReady(result); //run函数返回则线程结束
}
signals:
void resultReady(const QString &s);
};
void MyObject::startWorkInAThread()
{
WorkerThread *workerThread = new WorkerThread(this);
connect(workerThread, &WorkerThread::resultReady, this, &MyObject::handleResults);
connect(workerThread, &WorkerThread::finished, workerThread, &QObject::deleteLater);
workerThread->start();
}
然后调用QThread::start()启动线程。
结束线程可以用QThread::quit(),这个函数告诉线程停止事件循环并退出。和QThread::exit(0)等效。
调用完quit(),可以调用wait()等待线程结束。
这种情况下,由于run()函数没有执行事件循环,所以不能接收外部信号,但是可以向外部发送信号。
作为信号槽的容器
另一种就是让线程作为信号槽运行的容器。这时候不能再重载run()函数。run()默认执行自身的exec()函数去执行qt的事件循环。
这种情况下就可以继承QObject实现自己的类,然后将这个类用QObject::moveToThread()将自己的类托管给线程处理,自己只需要实现信号和槽函数。
下面的代码来自qt官方手册:
class Worker : public QObject
{
Q_OBJECT
public slots:
void doWork(const QString ¶meter) {
QString result;
/* ... here is the expensive or blocking operation ... */
emit resultReady(result);
}
signals:
void resultReady(const QString &result);
};
class Controller : public QObject
{
Q_OBJECT
QThread workerThread;
public:
Controller() {
Worker *worker = new Worker;
worker->moveToThread(&workerThread); //将自己的类托管给线程处理
connect(&workerThread, &QThread::finished, worker, &QObject::deleteLater);
connect(this, &Controller::operate, worker, &Worker::doWork);
connect(worker, &Worker::resultReady, this, &Controller::handleResults);
workerThread.start();
}
~Controller() {
workerThread.quit();
workerThread.wait();
}
public slots:
void handleResults(const QString &);
signals:
void operate(const QString &);
};
上面自定义的类 class Worker的槽函数运行在一个单独的线程中,就是用 workerThread这个线程实例。
如果有些操作比较耗时,就不能放在UI主线程里做,否则UI会卡顿。上面这样让Worker在doWork()里做脏活累活,做完了再通知主线程即可。