Qt源码阅读(二) moveToThread

Qt 源码分析之moveToThread

这一次，我们来看Qt中关于将一个QObject对象移动至一个线程的函数moveToThread

目录

• Qt 源码分析之moveToThread
  
  
  
  • Qt使用线程的基本方法
    
  • 源码分析
    
  • 一些线程和信号槽使用的心得
    
  
  

Qt使用线程的基本方法

首先，我们简单的介绍一下在Qt中使用多线程的几种方法:

• 重写QThread的run函数，将要在多线程执行的任务放到run函数里
  

1. /*mythread.h*/
2. #pragma once
4. #include <QThread>
6. class MyThread  : public QThread
7. {
8.     Q_OBJECT
10. public:
11.     explicit MyThread(QObject* parent = nullptr);
12.     ~MyThread();
14. protected:
15.     void run() override;
16. };
18. /*mythread.cpp*/
19. #include "mythread.h"
20. #include <QDebug>
22. MyThread::MyThread(QObject* parent)
23.     : QThread(parent)
24. {}
26. MyThread::~MyThread()
27. {}
29. void MyThread::run()
30. {
31.     /*
32.         在这个函数里执行耗时操作
33.     */
34.    for (auto a = 0; a < 10; a++) {
35.        qDebug() << u8"线程";
36.        QThread::sleep(1);
37.    }
38. }
40. /*调用函数*/
41. auto m_thread = new MyThread();
42. // 调用start之后，就会去执行run里内容了
43. m_thread->start();

复制代码

但是这种方法，不被Qt官方所推荐，Qt官方所推荐的是将对象移动至线程的方法moveToThread

• 创建一个QThread对象，将对象移动至一个线程中，用信号槽的方式来触发该对象的槽函数，此时槽函数是在线程中执行的
  

1. /*mytask.h*/
2. #pragma once
4. #include <QObject>
6. class MyTask  : public QObject
7. {
8.     Q_OBJECT
10. public:
11.     MyTask(QObject *parent = nullptr);
12.     ~MyTask();
14. public slots:
15.     void slotMyTask();
16. };
18. /*mytask.cpp*/
19. #include "mytask.h"
20. #include <QThread>
21. #include <QDebug>
23. MyTask::MyTask(QObject *parent)
24.     : QObject(parent)
25. {}
27. MyTask::~MyTask()
28. {}
30. void MyTask::slotMyTask()
31. {
32.     /* 在这里执行耗时操作 */
33.     for (auto a = 0; a < 10; a++) {
34.         qDebug() << u8"当前线程: " << QThread::currentThread();
35.         qDebug() << u8"线程";
36.         QThread::sleep(1);
37.     }
38. }
41. /*使用方法*/
42. // 1. 创建任务对象以及线程对象
43. auto m_task = new MyTask();
44. auto* m_thread = new QThread();
46. // 2. 将任务对象移动至线程
47. m_task->moveToThread(m_thread);
49. // 3. 将信号与任务类的槽连接起来
50. connect(m_thread, &QThread::started, m_task, &MyTask::slotMyTask);
52. //  4. 开启线程
53. m_thread->start();

复制代码

此时，我们看到控制台会输出：

Cannot move objects with a parent (无法移动一个有父对象的object)

并且，我们能看到槽函数里打印的线程为主线程。

• 使用Qt的QtConcurrent，缺点之一是没有办法手动退出
  

1. // 1. 创建一个有父对象的任务对象以及线程对象
2. auto m_task = new MyTask(this);
3. auto* m_thread = new QThread();
5. // 2. 将任务对象移动至线程
6. m_task->moveToThread(m_thread);
8. // 3. 将信号与任务类的槽连接起来
9. connect(m_thread, &QThread::started, m_task, &MyTask::slotMyTask);
11. //  4. 开启线程
12. m_thread->start();

复制代码

• 对要移动的对象当前所属线程的一些判断:
  
  
  
  • 如果要移动的对象没有线程依附性，那么可以移动至目标线程
    
  • 如果移动操作所在线程与移动对象所在线程不一致，那么不允许去移动
    
  
  

1. // 使用这个，需要在头文件里引入
2. #include <QtConcurrent/QtConcurrent>
4. // 定义一个任务函数
5. int MainWindow::taskTest(int a)
6. {
7.     for (auto i = 1; i < 10; i++) {
8.         qDebug() << "a: " << a;
9.         QThread::sleep(1);
10.     }
12.     return 0;
13. }
15. /* 使用方法 */
16. // 在函数后面跟上你要设置给函数的参数
17. QtConcurrent::run(this, &MainWindow::taskTest, 10);

复制代码

• 正式的移动操作
  

1. // 当前对象已经在目标线程了
2.     if (d->threadData.loadRelaxed()->thread.loadAcquire() == targetThread) {
3.         // object is already in this thread
4.         return;
5.     }
7.         // 不能移动一个有父对象的对象
8.     if (d->parent != nullptr) {
9.         qWarning("QObject::moveToThread: Cannot move objects with a parent");
10.         return;
11.     }
12.         // 窗口部件不能移动到一个新的线程，在Qt里GUI操作只能在主线程
13.     if (d->isWidget) {
14.         qWarning("QObject::moveToThread: Widgets cannot be moved to a new thread");
15.         return;
16.     }

复制代码

一些线程和信号槽使用的心得

到了夹带私活时间，下面是一些多线程使用信号槽的一点小心得总结

• 不能在子线程去更新UI界面，只能在主线程进行更新。
  
• 可以通过信号槽连接，在子线程通知主线程去更新UI
  
• 跨线程使用信号槽，建议用QueuedConnection，因为这种连接方式，Qt会把信号丢到事件循环里去，这样槽函数会在接收者所在的线程执行。而DirectConnection这种连接方式，因为是直接回调槽函数，槽会在信号发出的线程进行调用。具体可看上篇关于信号与槽源码分析。
  
• 但是使用QueuedConnection这种连接方式，信号的参数如果是自己定义的类型，一定要记得使用qRegisterMetaType来进行注册，或者使用Q_DECLARE_METATYPE来进行注册。否则，槽函数将不会触发。
  
• BlockQueuedConnection这种方法慎用，因为如果信号发送者和接收者在同一个线程，将会导致死锁。
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！