QT实现多线程编程

Posted 2022-05-18 MangataTS

文章目录

• • 一、项目需求
  • 二、QThread
  • • 2.1 头文件
    • 2.2 常用函数
  • 二、子进程
  • • 2.1 `mythread.h`
    • 2.2 `mythead.c`
  • 三、父进程

一、项目需求

主线程进行用户的交互，用户可以指定一个排序数组的大小，然后系统随机生成一个这么大的序列，然后子进程进行排序并且将这个序列返回给主线程，主线程读取后将数字序列填充在排序后的位置

二、QThread

QT自己封装了一个QThread 的类，我们直接继承它并且实现其中的部分函数就可以

2.1 头文件

#include <QThread>

2.2 常用函数

我们需要将这个进程要做的事情放在run()函数中，当然也可以放一些自己的函数然后实现

二、子进程

2.1 mythread.h

这里我们需要将我们的子进程类定义，首先是继承QThread然后定义一些自己需要用到的函数

#ifndef MYTHREAD_H
#define MYTHREAD_H

#include <QObject>
#include <QThread>
#include<QVector>

//生成随机数
class MyThread : public QThread

    Q_OBJECT
public:
    explicit MyThread(QObject *parent = nullptr);
    void  recvNum(int  num);
protected:
    void run() override;

signals:
    void  sendArray(QVector<int>  array);
private:
    int  m_num;

;

#endif // MYTHREAD_H

2.2 mythead.c

这里负责实现这个子进程类的一些函数：

#include "mythread.h"
#include <QElapsedTimer>
#include <QDebug>
#include <QTime>
MyThread::MyThread(QObject *parent) : QThread(parent)



void  MyThread::recvNum(int num)
    m_num = num;
    qDebug("num = %d\\n",num);

void MyThread::run()
    qsrand(QTime(0,0,0).secsTo(QTime::currentTime()));
    qDebug()<<"线程地址："<<QThread::currentThreadId();
    QVector<int> list;
    QElapsedTimer time;
    time.start();
    for(int i = 0;i < m_num;++i)
        list.push_back(qrand()%1000);
    
    int mistime = time.elapsed();
    qDebug("mistime = %d\\n",mistime);
    emit sendArray(list);

这里我们接收到了按钮绑定的一个信号槽，只要每次点击按钮就会触发这个信号，然后将num传送过来，我们线程中的run()函数，打印一些调试信息，并且随机生成一个序列

三、父进程

这里负责绑定一些信号槽，以及实现信号传输后的一些操作，例如每次点击开始就清空一下显示框、传入排序后的数字

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include "mythread.h"
#include <algorithm>


MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)

    ui->setupUi(this);
    //创建子线程的对象
    MyThread *  fristThread = new MyThread();
    //随机数播种

    //启动子线程  是不是要点击开始就会去生成随机数
    //主线程往子线程传递参数 ，还是需要借助connect（）
    connect(this,&MainWindow::starting,fristThread,&MyThread::recvNum);
    connect(ui->start,&QPushButton::clicked,this,[=]()
         //清空两个显示框
         ui->tobetter->clear();
         ui->randlist->clear();
         //想办法传入 num的 循环次数
         int num = ui->spinBox->value();
         emit starting(num);
         fristThread->start();
     );
     //接收子线程函数处理过后发过来的数据
     connect(fristThread,&MyThread::sendArray,this,[=](QVector<int> list)
         int n = list.size();
         for(int i=0;i< n ;i++)
             ui->randlist->addItem(QString::number(list.at(i)));
         
         std::sort(list.begin(),list.end());
         for(int i = 0;i < n; ++i) 
             ui->tobetter->addItem(QString::number(list.at(i)));
         
     );


MainWindow::~MainWindow()

    delete ui;