首页 > 编程语言 >QT 线程 QThread QT5.12.3环境 C++实现

QT 线程 QThread QT5.12.3环境 C++实现

时间:2024-11-22 11:46:34浏览次数:3  
标签:Widget QT thread void C++ flag 线程 include

一、线程

   QT主线程称为GUI线程,负责初始化界面并监听事件循环,并根据事件处理做出界面上的反馈。如果把一些比较复杂或者费时的操作放在主线程中,界面就会出现卡顿或者无响应的现象。一般主线程负责影响界面上的操作, 子线程负责负责费时的数据处理。


二、使用多线程有什么好处

1. 提高应用界面的响应速度。

        这对于开发图形界面程序尤其重要,当一个操作耗时很长时(比如大批量I/O或大量矩阵变换等CPU密集操作),整个系统都会等待这个操作,程序就不能响应键盘、鼠标、菜单等操作,而使用多线程技术可将耗时长的操作置于一个新的线程,从而不会影响到主GUI线程,从而避免上述问题。

2. 使多核心CPU系统更加有效。

        当线程数不大于CPU核数时,操作系统可以调度不同的线程运行于不同的CPU核上。

3. 改善程序结构。

        一个既长又复杂的进程可以考虑分为多个线程,成为独立或半独立的运行部分,这样有利于程序的理解和维护。

界面操作只能由主线程来操作,其他线程负责处理复杂数据.


三、QThread类常用的方法

Public Functions
	QThread(QObject *parent = 0) //构造函数  //pthread_create
	bool isFinished() const  //判断线程是否退出
	bool	wait(unsigned long time = ULONG_MAX)   //pthread_join(&id)
	//等待某个线程结束,最多等待time ms,如果时间没有设置,那么永远等待。

Public Slots
	void	start(Priority priority = InheritPriority)  //启动线程必须使用start
	void	terminate()-->杀死线程  //pthread_cancel

Static Public Members
	Qt::HANDLE	currentThreadId() [static] //得到当前执行者线程ID,可以直接qDebug
	void	sleep(unsigned long secs) [static]
	void	msleep(unsigned long msecs) [static]
	void	usleep(unsigned long usecs) [static]

	睡眠函数不能在主线程调用,会造成界面卡死。

Protected Functions	
	virtual void run();  //启动新线程不能直接调用run,需要调用start接口,
						//start会启动新线程,然后执行run里的代码块。

四、重写run方法创建线程步骤

1、自定义类继承于QThread。

2、重写 run 函数,run函数内有一个 while 或 for 的循环:执行耗时操作。

3、在主线程中,创建自定类类型的对象,调用start方法启动线程, run方法就是新线程的入口函数。

4、主线程通过调用子线程的公有方法传递参数给子线程。

5、子线程通过信号与槽传递参数给主线程。

6、通过quit+wait方法,通知线程退出,回收线程资源。但wait是一个阻塞方法,如果线程没有退出,wait阻塞等待。一般子线程会设置一个标记为来控制循环的退出,并提供一个公有方法设置标记值。当通知线程退出时,在主线程中调用设置标志的公有方法,将循环条件设为假,线程退出,这时wait回收子线程资源不会造成阻塞。

7、关闭窗口时,要对其他子线程进行管理. 关闭窗口时,窗口会发出destroyed信号,可以通过连接该信号来管理子线程。在QT6中,可能不执行这个信号的槽方法,可以通过重现closeEvent事件来处理。


案例需求:在子线程中, 1秒中输出1个整型的数字, 将数字传到主线程, 在主线程的Label中显示。


代码:

mtthread.h

#ifndef MTTHREAD_H
#define MTTHREAD_H

#include <QObject>
#include <QThread>
#include <QDebug>
class MtThread : public QThread
{
    Q_OBJECT
public:
    explicit MtThread(QObject *parent = nullptr);
    void run();
    void set_flag(int flag);
signals:
    void my_signal(int n);
public slots:

private:
    int flag = 1;
};

#endif // MTTHREAD_H

widget.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include "mtthread.h"
namespace Ui {
class Widget;
}

class Widget : public QWidget
{
    Q_OBJECT

public:
    explicit Widget(QWidget *parent = nullptr);
    ~Widget();
private slots:
    void on_pushButton_clicked();

    void on_pushButton_2_clicked();

    void my_signal_slot(int n);

private:
    Ui::Widget *ui;
    MtThread *thread;
};

#endif // WIDGET_H

mtthread.cpp

#include "mtthread.h"

MtThread::MtThread(QObject *parent) : QThread(parent)
{

}

void MtThread::run()
{
    static int n = 0;
    qDebug()<<"current thread:"<<QThread::currentThread();
    while(flag){
        qDebug()<<"n = "<<n++;
        emit my_signal(n); // 发送信号
        sleep(1);
    }
}

void MtThread::set_flag(int flag)
{
    this->flag = flag;
}

widget.cpp

#include "widget.h"
#include "ui_widget.h"

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

    thread = new MtThread(this);
    qDebug()<<"main thread:"<<QThread::currentThread();

    connect(this,&Widget::destroyed,this,&Widget::on_pushButton_2_clicked); // 直接点击 X 也能销毁线程
    connect(thread,&MtThread::my_signal,this,&Widget::my_signal_slot);
}

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

void Widget::on_pushButton_clicked()
{
    thread->start(); // 启动线程
}

void Widget::on_pushButton_2_clicked()
{
    thread->quit(); // (通知)线程退出 (如果任务没做完不会结束!)
    // 线程结束的条件 --> run()运行结束 --> 循环条件为假
    thread->set_flag(0);
    thread->wait(); // 回收线程资源,如果线程没有退出,wait()是一个阻塞函数
    this->close();
}

void Widget::my_signal_slot(int n)
{
    ui->label->setText(QString::number(n));
}

输出:


五、moveToThread方法创建线程步骤

1自定义类继承于QObject, 实现线程的入口函数,方法名自定义。

2主线程中实例化自定义类对象和QThread类型的对象。

3将自定义对象移动到QThread线程中。

4、启动线程, 必须通过信号与槽,让自定义类类型对象调用相应的方法,这个方法就是放到线程中执行(注意:启动线程调用start方法,在这个方法中会发送started信号)。

5、主线程通过调用子线程的公有方法传递参数给子线程。

6、子线程通过信号与槽传递参数给主线程。

7、通过quit+wait方法,通知线程退出,回收线程资源。但wait是一个阻塞方法,如果线程没有退出,wait阻塞等待。一般子线程会设置一个标记为来控制循环的退出,并提供一个公有方法设置标记值。当通知线程退出时,在主线程中调用设置标志的公有方法,将循环条件设为假,线程退出,这时wait回收子线程资源不会造成阻塞。

8、关闭窗口时,要对其他子线程进行管理. 关闭窗口时,窗口会发出destroyed信号,可以通过连接该信号来管理子线程。在QT6中,可能不执行这个信号的槽方法,可以通过重现closeEvent事件来处理。


案例需求:在子线程中, 1秒中输出1个整型的数字, 将数字传到主线程, 在主线程的Label中显示。


代码:

mytask.h

#ifndef MYTASK_H
#define MYTASK_H

#include <QObject>
#include <QDebug>
#include <QThread>
class MyTask : public QObject
{
    Q_OBJECT
public:
    explicit MyTask(QObject *parent = nullptr);
    void thread_task();
    void set_flag(int flag);
signals:
    void my_signal(int n);
public slots:

private:
    int flag = 1;
};

#endif // MYTASK_H

widget.h

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include <QDebug>
#include <QThread>
#include "mytask.h"

namespace Ui {
class Widget;
}

class Widget : public QWidget
{
    Q_OBJECT

public:
    explicit Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:
    void on_pushButton_clicked();

    void on_pushButton_2_clicked();

private:
    Ui::Widget *ui;
    QThread *thread;
    MyTask *task;
};

#endif // WIDGET_H

mytask.cpp

#include "mytask.h"

MyTask::MyTask(QObject *parent) : QObject(parent)
{

}

void MyTask::thread_task()
{
    static int n = 0;
    while(flag){
        qDebug()<<"n = "<<n++;
        emit my_signal(n);
        QThread::sleep(1);
    }
}

void MyTask::set_flag(int flag)
{
    this->flag = flag;
}

widget.cpp

#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);
    thread = new QThread(this);
    qDebug()<<"main thread:"<<QThread::currentThread();

    task = new MyTask; // 不能指定父对象

    task->moveToThread(thread); // 把task移动到thread线程中
    connect(thread,&QThread::started,task,&MyTask::thread_task); // 不能直接调用MyTask里的函数,只能通过槽连接
     connect(this,&Widget::destroyed,this,&Widget::on_pushButton_2_clicked); // 直接点击 X 也能销毁线程
     connect(task,&MyTask::my_signal,this,[=](int n){ // 只能在主线程对界面进行操作
         this->ui->label->setText(QString::number(n));
     });
}

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

void Widget::on_pushButton_clicked()
{
    thread->start(); // 启动线程,发送start()信号
}

void Widget::on_pushButton_2_clicked()
{
    thread->quit();
    task->set_flag(0);
    thread->wait();
}

输出:


案例需求:通过线程,实现电子时钟。


代码:

mytime.h

#ifndef MYTIME_H
#define MYTIME_H
 
#include <QObject>
#include <QDebug>
#include <QThread>
#include <QDateTime>
class MyTime : public QObject
{
    Q_OBJECT
public:
    explicit MyTime(QObject *parent = nullptr);
    void thread_time();
    void set_flag(int flag);
signals:
    void my_signal(QString datatime);
public slots:
 
private:
    int flag = 1;
};
 
#endif // MYTIME_H

widget.h

#ifndef WIDGET_H
#define WIDGET_H
 
#include <QWidget>
#include <QDebug>
#include <QThread>
#include "mytime.h"
 
namespace Ui {
class Widget;
}
 
class Widget : public QWidget
{
    Q_OBJECT
 
public:
    explicit Widget(QWidget *parent = nullptr);
    ~Widget();
 
private slots:
    void on_pushButton_clicked();
 
    void on_pushButton_2_clicked();
 
private:
    Ui::Widget *ui;
    QThread *thread;
    MyTime *time;
};
 
#endif // WIDGET_H

mytime.cpp

#include "mytime.h"
 
MyTime::MyTime(QObject *parent) : QObject(parent)
{
 
}
 
void MyTime::thread_time()
{
    while(flag){
        QDateTime currentTime = QDateTime::currentDateTime();
        QString formattedTime = currentTime.toString("hh:mm:ss");
        qDebug() << formattedTime;
        emit my_signal(formattedTime);
        QThread::sleep(1);
    }
}
 
void MyTime::set_flag(int flag)
{
    this->flag = flag;
}

widget.cpp

#include "widget.h"
#include "ui_widget.h"
 
Widget::Widget(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);
    thread = new QThread(this);
    time = new MyTime; // 不能指定父对象
    ui->lcdNumber->setDigitCount(8);
    time->moveToThread(thread); // 移动到thread线程中
    connect(thread,&QThread::started,time,&MyTime::thread_time);
    connect(this,&Widget::destroyed,this,&Widget::on_pushButton_2_clicked); // 直接点击 X 也能销毁线程
    connect(time,&MyTime::my_signal,this,[=](QString datatime){ // 只能在主线程对界面进行操作
        this->ui->lcdNumber->display(datatime);
    });
}
Widget::~Widget()
{
    delete ui;
}
 
void Widget::on_pushButton_clicked()
{
    thread->start();
}
 
void Widget::on_pushButton_2_clicked()
{
         thread->quit();
         time->set_flag(0);
         thread->wait();
}

输出:


六、connect最后一个参数

表示连接类型,默认是自动连接。有如下几种选择:

Qt::AutoConnection (0)

        这是默认的连接类型。Qt会根据信号发射者接收者(slot所在的对象)是否位于发射信号的线程中,自动选择使用Qt::DirectConnectionQt::QueuedConnection。如果接收者和发射者位于同一线程,则使用Qt::DirectConnection;否则,使用Qt::QueuedConnection

Qt::DirectConnection (1)

        当信号被发射时,槽函数会立即在同一线程中被调用。这种连接类型适用于槽函数不需要跨线程执行的场景,因为它避免了线程切换的开销。

Qt::QueuedConnection (2)

        信号被发射后,槽函数的调用会被排入接收者对象所在线程的事件循环中。这意味着槽函数将在接收者对象的线程中执行,但不一定是在信号发射后立即执行。这种连接类型适用于跨线程通信,确保了线程安全。

Qt::BlockingQueuedConnection (3)

        这种连接类型与Qt::QueuedConnection类似,但有一个关键区别:发射信号的线程会在槽函数执行完毕并返回之前被阻塞。这意呀着,如果接收者(槽函数)位于发射信号的同一线程中,使用这种连接类型将导致死锁,因为发射信号的线程会等待它自己来完成槽函数的执行。

Qt::UniqueConnection (0x80)

        这不是一个独立的连接类型,而是一个可以与上述任何连接类型通过位或(bitwise OR)操作组合使用的标志。当设置了Qt::UniqueConnection时,如果指定的信号和槽之间的连接已经存在,QObject::connect()函数将不会建立新的连接,并返回false。这有助于避免重复连接同一信号到同一槽,尤其是在动态连接信号和槽时非常有用。

标签:Widget,QT,thread,void,C++,flag,线程,include
From: https://blog.csdn.net/2301_77329667/article/details/143967648

相关文章