參考博客1:QThread詳解
參考博客2:Qt之線程(QThread)
參考博客3:QT 多線程程序設計
參考博客4:Qt之QThread(深入理解)
QThread類提供了一個平臺無關的方式來管理線程涤躲。
一個QThread對象在程序控制中管理一個線程俱尼。線程在run()中開始執(zhí)行律胀。默認情況下欲间,run()通過調用exec()啟動事件循環(huán)并在線程里運行一個Qt的事件循環(huán)办龄。
執(zhí)行結束時呐伞,將會返回run()函數(shù)的執(zhí)行結果。 當線程啟動瘟檩、結束抹缕、終結時,他會通過發(fā)送一個信號來通知你墨辛。你可以通過isFinished()和isrunning來查詢線程的狀態(tài)卓研。
QThread 的兩種使用方法:
1、子類化 QThread(不使用事件循環(huán))睹簇。
這是官方手冊奏赘、例子以及相關書籍中都介紹的一種常用的方法。
a. 子類化 QThread,創(chuàng)建對象太惠,并調用start()函數(shù)
b. 重載 run 函數(shù)磨淌,run函數(shù)內有一個while或for的死循環(huán)(模擬耗時操作)
c. 設置一個標記為來控制死循環(huán)的退出。
2凿渊、子類化 QObject
a. 子類化 QObject
b. 定義槽函數(shù)
c. 將該子類的對象moveToThread到新線程中
若程序退出時梁只,次線程還在運行,未正常退出
我們應該采取合理的措施來優(yōu)雅地結束線程埃脏,一般思路:
發(fā)起線程退出操作搪锣,調用quit()或exit()。
等待線程完全停止彩掐,刪除創(chuàng)建在堆上的對象构舟。
適當?shù)氖褂脀ait()(用于等待線程的退出)和合理的算法。
下面的代碼按照參考博客4(使用Qt5)修改而來堵幽,可在Qt4.8上面運行:
使用的方法1
WorkerThread.h
#ifndef WORKERTHREAD_H
#define WORKERTHREAD_H
#include <QThread>
#include <QMutex>
#include <QDebug>
class WorkerThread : public QThread
{
Q_OBJECT
public:
explicit WorkerThread(QObject *parent = 0)
: QThread(parent),
m_bStopped(false)
{
qDebug() << "Worker Thread : " << QThread::currentThreadId();
}
~WorkerThread()
{
stop();
quit();
wait();//
}
void stop()
{
qDebug() << "Worker Stop Thread : " << QThread::currentThreadId();
QMutexLocker locker(&m_mutex);
m_bStopped = true;
}
protected:
virtual void run() {
qDebug() << "Worker Run Thread : " << QThread::currentThreadId();
int nValue = 0;
while (nValue < 100)
{
// 休眠50毫秒
msleep(50);
++nValue;
// 準備更新
emit resultReady(nValue);
// 檢測是否停止
{
QMutexLocker locker(&m_mutex);
if (m_bStopped)
break;
}
// locker超出范圍并釋放互斥鎖
}
}
signals:
void resultReady(int value);
private:
//QMutex互斥鎖 + bool成員變量旁壮,
bool m_bStopped;
QMutex m_mutex;
};
#endif // WORKERTHREAD_H
QMyWidget.h
#ifndef QMYWIDGET_H
#define QMYWIDGET_H
#include <QWidget>
#include <QProgressBar>
#include "WorkerThread.h"
class QMyWidget : public QWidget
{
Q_OBJECT
public:
explicit QMyWidget(QWidget *parent = 0);
~QMyWidget();
private slots:
// 更新進度
void handleResults(int value);
// 開啟線程
void startThread();
private:
QProgressBar *m_pProgressBar;
WorkerThread m_workerThread;
};
#endif
QMyWidget.cpp
#include "QMyWidget.h"
#include <QPushButton>
#include <QVBoxLayout>
QMyWidget:: QMyWidget(QWidget *parent)
: QWidget(parent)
{
qDebug() << "Main Thread : " << QThread::currentThreadId();
// 創(chuàng)建開始按鈕、進度條
QPushButton *pStartButton = new QPushButton(this);
m_pProgressBar = new QProgressBar(this);
//設置文本谐檀、進度條取值范圍
pStartButton->setText(QString::fromLocal8Bit("開始"));
m_pProgressBar->setFixedHeight(25);
m_pProgressBar->setRange(0, 100);
m_pProgressBar->setValue(0);
QVBoxLayout *pLayout = new QVBoxLayout();
pLayout->addWidget(pStartButton, 0, Qt::AlignHCenter);
pLayout->addWidget(m_pProgressBar);
pLayout->setSpacing(50);
pLayout->setContentsMargins(10, 10, 10, 10);
setLayout(pLayout);
// 連接信號槽
connect(pStartButton, SIGNAL(clicked(bool)), this, SLOT(startThread()));
connect(&m_workerThread, SIGNAL(resultReady(int)), this, SLOT(handleResults(int)));
// 線程結束后抡谐,自動銷毀
//connect(&m_workerThread, SIGNAL(finished()), &m_workerThread, SLOT(deleteLater()));
}
QMyWidget::~QMyWidget(){}
// 更新進度
void QMyWidget::handleResults(int value)
{
qDebug() << "Handle Thread : " << QThread::currentThreadId();
m_pProgressBar->setValue(value);
}
// 開啟線程
void QMyWidget::startThread()
{
if(!m_workerThread.isRunning()){
m_workerThread.start();
}
}
main.cpp
#include <QtGui/QApplication>
#include "QMyWidget.h"
int main(int argc, char *argv[])
{
QApplication a(argc, argv);
QMyWidget w;
w.show();
return a.exec();
}