掌握Qt的QThread：深入多线程编程

掌握Qt的QThread：深入多线程编程

引用

CSDN

1.

https://blog.csdn.net/festaw/article/details/140276935

引言

在现代软件开发中，多线程编程已成为提升应用性能和响应性的关键技术。Qt 提供了一套完整的多线程解决方案，其中
QThread
是核心组件之一。本文将详细介绍如何在 Qt 应用程序中使用
QThread
来实现多线程处理。
Qt的线程实现主要两种方式：子类化QThread和对象moveToThread。

子类化QThread

实现方法

1. 继承QThread：创建一个新类，继承自
   QThread
   。
2. 重写run()：在新类中重写
   run()
   方法，实现线程执行的逻辑。
3. 启动线程：在其他线程中使用
   start()
   函数来启动此线程。

缺点

• 对象创建限制：线程中的对象必须在
  run()
  函数中创建。
• 信号接收限制：线程无法接收信号，只能发送信号。

对象moveToThread

实现方式

1. 新建Worker类：在Worker类的槽函数中实现业务逻辑。
2. 创建QThread对象：实例化一个
   QThread
   对象。
3. 移动对象到线程：将Worker的实例使用
   moveToThread()
   移动到新线程。
4. 连接信号和槽：确保相关信号和槽正确连接。
5. 触发执行：在其他线程发射信号，Worker的槽函数将在目标线程中执行。

优缺点

• 优点：提供了一种灵活简洁的方式来克服子类化
  QThread
  的缺点，允许在线程中执行复杂的业务逻辑。
• 缺点：不适合实现需要在线程中常驻执行的任务（如死循环任务）。

适用场景

• 轻量级函数：适用于需要在线程中执行多个小函数的情况。
• 代码重构：在最初未考虑多线程，但后续需要将部分代码迁移到线程中的场景。

细节注意点

• 槽函数执行：只有槽函数会在新线程中执行。
• 父对象问题：在创建Worker类实例时，不要指定父对象，否则
  moveToThread()
  会失败。

多线程基础

线程（Thread）

线程是程序执行的独立流，它允许多个任务同时进行。每个线程可以看作是程序中的一个执行单元，拥有自己的栈空间和寄存器，但与其他线程共享程序的内存空间。这意味着多个线程可以同时访问相同的数据和资源。

线程的生命周期

• 创建：当线程对象被实例化时，它处于创建状态。
• 就绪：线程准备好执行，等待CPU时间。
• 运行：线程正在执行其任务。
• 阻塞：线程等待某个事件（如I/O操作）完成。
• 死亡：线程完成执行或被显式终止。

线程安全（Thread Safety）

线程安全是指在多线程环境中，程序的行为符合预期，且数据的完整性和一致性得到保证。为了实现线程安全，需要确保：

• 原子操作：确保操作不可被中断，要么完全执行，要么完全不执行。
• 互斥访问：在任何时刻，只有一个线程可以访问特定的数据或资源。
• 条件同步：使用条件变量和信号量来控制线程间的协调。
  

同步（Synchronization）

同步是多线程编程中用于控制线程间交互的机制，以防止多个线程同时访问共享资源，从而避免数据竞争和一致性问题。

常见的同步机制包括：

• 互斥锁（Mutex）：一种锁机制，确保一次只有一个线程可以访问特定的代码段。
• 信号量（Semaphore）：一种计数器，用来控制对共享资源的访问数量。
• 读写锁（Read-Write Lock）：允许多个线程同时读取数据，但写入时需要独占访问。
• 条件变量（Condition Variable）：一种同步对象，使线程能够在某些条件不满足时挂起，并在条件满足时被唤醒。

死锁（Deadlock）

死锁是多线程编程中常见的问题，发生在两个或多个线程相互等待对方释放资源，但没有一个线程能够继续执行的情况。避免死锁的策略包括：

• 锁定顺序：总是以相同的顺序获取多个锁。
• 超时：尝试获取锁时使用超时机制。
• 死锁检测：定期检查潜在的死锁情况。

线程局部存储（Thread Local Storage）

线程局部存储是指每个线程独有的数据存储区域，其他线程无法访问。这可以通过
QThreadLocal
在Qt中实现，用于存储线程特定的数据，如用户信息、会话ID等。

QThread
简介
QThread
是 Qt 中用于执行线程的类。它允许你将耗时的任务移到后台线程执行，从而不会阻塞用户界面。

创建和启动线程

  
QThread *thread = new QThread();
MyClass *myObject = new MyClass(); // 假设 MyClass 有 run 方法
myObject->moveToThread(thread);
connect(thread, &QThread::started, myObject, &MyClass::run);
connect(this, &MyClass::finished, thread, &QThread::quit);
connect(thread, &QThread::finished, myObject, &QObject::deleteLater);
connect(thread, &QThread::finished, thread, &QThread::deleteLater);
thread->start();
  

定义线程执行的任务

你需要确保你的任务类继承自
QObject
并重写
run
方法：

  
class MyClass : public QObject {
    Q_OBJECT
public:
    void run() {
        // 执行耗时任务
    }
};
  

线程的生命周期管理

使用
moveToThread
方法将对象移动到新线程，并通过信号和槽管理线程的生命周期。

QThread::start()
启动线程。

QThread::quit()
请求线程安全退出。

QThread::finished()
线程完成任务后自动退出。

线程间的通信

使用信号和槽实现线程间的通信：

  
connect(myObject, &MyClass::resultReady, this, &MainWindow::handleResult);
  

线程同步

使用互斥锁（
QMutex
）和读写锁（
QReadWriteLock
）来同步线程对共享资源的访问。

  
QMutex mutex;
mutex.lock();
// 访问共享资源
mutex.unlock();
  

等待线程完成

使用
QThread::wait()
使主线程等待工作线程完成：

  
thread->wait();