QT 多线程 QThread
继承QThread的线程
#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>
#include <QThread>
#include <QDebug>
#include <QPushButton>
class WorkerThread;
class MainWindow : public QMainWindow
{
Q_OBJECT
public:
MainWindow(QWidget *parent = nullptr);
~MainWindow();
private:
QPushButton *pushButton;
WorkerThread *workThread;
private slots:
void handleResults(const QString &result);
void pushButtonClicked();
};
class WorkerThread : public QThread
{
Q_OBJECT
public:
WorkerThread(QWidget *parent = nullptr){
Q_UNUSED(parent);
}
void run() override {
QString result = "Thread Start";
/*
* Timerout
*/
sleep(2);
emit resultReady(result);
}
signals:
void resultReady(const QString &s);
};
#endif // MAINWINDOW_H
#include "mainwindow.h"
MainWindow::MainWindow(QWidget *parent)
: QMainWindow(parent)
{
this->setGeometry(0,0,800,480);
pushButton = new QPushButton(this);
workThread = new WorkerThread(this);
pushButton->resize(100,40);
pushButton->setText("Start Thread");
/* 信号槽连接 */
connect(workThread, &WorkerThread::resultReady,
this, &MainWindow::handleResults);
connect(pushButton, &QPushButton::clicked,
this, &MainWindow::pushButtonClicked);
}
MainWindow::~MainWindow()
{
workThread->quit();
if(workThread->wait(2000)){
qDebug() << "Thread end" << endl;
}
}
void MainWindow::handleResults(const QString &result)
{
qDebug() << result << endl;
}
void MainWindow::pushButtonClicked()
{
if (!workThread->isRunning())
workThread->start();
}
上述代码很简单,相信都能看懂。
主窗口构造函数:当创建 MainWindow 对象时,构造函数设置窗口尺寸,初始化按钮和工作线程,并连接信号槽。
按钮点击事件:当用户点击按钮时,调用 pushButtonClicked 槽函数,启动线程。
线程执行:线程开始运行,暂停2秒,然后发出 resultReady 信号。
结果处理:信号槽机制确保 handleResults 槽函数被调用,输出线程结果。
主窗口析构函数:在销毁 MainWindow 对象时,确保线程被正确终止并释放资源。
效果:
继承QObject的线程
#include "mainwindow.h"
MainWindow::MainWindow(QWidget *parent)
: QMainWindow(parent)
{
this->setGeometry(0,0,800,480);
pushButton1 = new QPushButton(this);
pushButton2 = new QPushButton(this);
pushButton1->setGeometry(300, 200, 80, 40);
pushButton2->setGeometry(400, 200, 80, 40);
pushButton1->setText(" Start Thread ");
pushButton2->setText(" failed Thread ");
worker = new Worker;
worker->moveToThread(&workerThread);
/* 线程完成销毁对象 */
connect(&workerThread, SIGNAL(finished()),
worker, SLOT(deleteLater()));
connect(&workerThread, SIGNAL(finished()),
&workerThread, SLOT(deleteLater()));
/* 发送开始工作的信号,开始工作 */
connect(this, SIGNAL(startWork(QString)),
worker, SLOT(doWork1(QString)));
/* 接收到 worker 发送过来的信号 */
connect(worker, SIGNAL(resultReady(QString)),
this, SLOT(handleResults(QString)));
/* 点击按钮开始线程 */
connect(pushButton1, SIGNAL(clicked()),
this, SLOT(pushButton1Clicked()));
/* 点击按钮打断线程 */
connect(pushButton2, SIGNAL(clicked()),
this, SLOT(pushButton2Clicked()));
}
MainWindow::~MainWindow()
{
worker->stopwork();
workerThread.quit();
if(workerThread.wait(2000)){
qDebug() << "Thread end" << endl;
}
}
void MainWindow::handleResults(const QString &result)
{
qDebug() << result << endl;
}
void MainWindow::pushButton1Clicked()
{
const QString str = "";
if (!workerThread.isRunning())
workerThread.start();
emit this->startWork(str);
}
void MainWindow::pushButton2Clicked()
{
if(workerThread.isRunning()){
worker->stopwork();
}
}
#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>
#include <QThread>
#include <QDebug>
#include <QPushButton>
#include <QMutexLocker>
#include <QMutex>
class Worker;
class MainWindow : public QMainWindow
{
Q_OBJECT
public:
MainWindow(QWidget *parent = nullptr);
~MainWindow();
private:
QPushButton *pushButton1;
QPushButton *pushButton2;
QThread workerThread;
Worker *worker;
private slots:
void handleResults(const QString &result);
void pushButton1Clicked();
void pushButton2Clicked();
signals:
void startWork(const QString &);
};
class Worker : public QThread
{
Q_OBJECT
private:
QMutex lock;
bool isCanRun;
public slots:
void doWork1(const QString ¶meter){
isCanRun = true;
while(1){
{
QMutexLocker locker(&lock);
if(!isCanRun){
break;
}
}
QThread::sleep(2);
emit resultReady(parameter + " dowork1 thread ");
}
emit resultReady("stop work1 thread");
}
public:
void stopwork(){
qDebug() << "thread failed" << endl;
QMutexLocker locker(&lock);
isCanRun = false;
}
signals:
void resultReady(const QString &result);
};
#endif // MAINWINDOW_H
原文地址:https://blog.csdn.net/weixin_64593595/article/details/140377082
免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!