Qt 中线程使用
在 Qt 中，线程的管理和使用非常重要，特别是在需要并发处理和避免界面卡顿的情况下。Qt 提供了几种方式来创建和管理线程，最常用的有 QThread 类和通过继承 QRunnable 的线程池。下面我将分别介绍这几种方式。
1. QThread 基本用法
QThread 是 Qt 提供的线程管理类，可以通过它创建和管理独立的线程。您可以将任务移到线程中执行，而不会阻塞主线程。
1.1. 继承 QThread 创建线程
您可以通过继承 QThread 类并重写 run() 方法来创建线程。
#include <QCoreApplication>
#include <QThread>
#include <QDebug>// 创建一个继承自 QThread 的类
class WorkerThread : public QThread {Q_OBJECT
public:WorkerThread() {}protected:void run() override {// 这里是线程执行的任务for (int i = 0; i < 5; ++i) {qDebug() << "Worker thread is running, iteration:" << i;QThread::sleep(1); // 模拟耗时操作}emit finished(); // 发出 finished 信号，表示线程完成任务}signals:void finished(); // 线程完成信号
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);WorkerThread workerThread;QObject::connect(&workerThread, &WorkerThread::finished, &a, &QCoreApplication::quit);workerThread.start(); // 启动线程return a.exec();
}
1.2. 使用 moveToThread()
如果你不想继承 QThread，可以通过 moveToThread() 将一个对象移到一个新的线程中执行。
#include <QCoreApplication>
#include <QThread>
#include <QObject>
#include <QDebug>class Worker : public QObject {Q_OBJECT
public:Worker() {}public slots:void doWork() {qDebug() << "Worker thread is running!";QThread::sleep(2); // 模拟耗时操作emit finished();}signals:void finished();
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);Worker worker;QThread thread;// 将 worker 移到新的线程中worker.moveToThread(&thread);// 当线程启动时，调用 worker 的 doWork 方法QObject::connect(&thread, &QThread::started, &worker, &Worker::doWork);// 线程完成后退出QObject::connect(&worker, &Worker::finished, &a, &QCoreApplication::quit);thread.start(); // 启动线程return a.exec();
}
2. 使用线程池 (QRunnable + QThreadPool)
对于大量短时间运行的任务，线程池是一个更高效的选择，避免了频繁创建和销毁线程的开销。QThreadPool 类可以管理和调度 QRunnable 对象。
2.1. 使用 QRunnable
QRunnable 允许将任务提交到线程池执行，而不需要直接创建 QThread 对象。
#include <QCoreApplication>
#include <QThreadPool>
#include <QRunnable>
#include <QDebug>class Task : public QRunnable {
public:void run() override {// 任务逻辑qDebug() << "Task is running in thread:" << QThread::currentThread();QThread::sleep(1); // 模拟任务执行}
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);// 获取默认线程池QThreadPool *pool = QThreadPool::globalInstance();// 创建并提交任务for (int i = 0; i < 5; ++i) {Task *task = new Task();pool->start(task); // 启动任务}return a.exec();
}
2.2. 线程池的参数设置
QThreadPool 允许你设置最大线程数、优先级等参数：
QThreadPool *pool = QThreadPool::globalInstance();
pool->setMaxThreadCount(10); // 设置最大线程数
pool->start(task); // 启动任务
3. 线程间通信
在 Qt 中，线程之间的通信通常使用信号和槽。由于 Qt 的事件循环机制，线程间的信号和槽可以安全地跨线程传递数据。
3.1. 跨线程信号和槽
在 Qt 中，线程间的信号和槽是异步的。默认情况下，Qt 会自动将信号从一个线程排队到另一个线程。通过 Qt::QueuedConnection 连接类型，可以保证线程间信号的安全传递。
// 假设 worker 运行在一个线程中
connect(worker, &Worker::finished, this, &MainWindow::onWorkerFinished, Qt::QueuedConnection);
4. 注意事项
- 线程安全： 在多线程编程中，必须保证对共享数据的访问是线程安全的。可以使用 QMutex、QMutexLocker 来避免数据竞争。
- 避免 UI 阻塞： 在 GUI 应用程序中，耗时操作必须在子线程中执行，避免阻塞主线程的事件循环，确保 UI 不会冻结。
- 线程终止： 通常不要直接调用 QThread::terminate() 来强行结束线程。可以通过设计良好的线程控制信号来安全地终止线程。
5. 总结
- QThread： 适用于需要执行耗时操作并与界面进行交互的场景。
- QRunnable + QThreadPool： 适用于大量短任务的场景，避免了频繁创建和销毁线程的开销。
- 跨线程通信： 使用信号和槽进行线程间的通信，确保线程安全。