Qt基于等待条件QWaitCondition实现的任务队列模型示例

核心概念

Qt中的QWaitCondition是一个用于多线程同步的类，允许线程在某些条件满足时唤醒其他等待的线程。它通常与QMutex配合使用，协调线程之间的执行顺序，适用于生产者-消费者模型、任务队列调度等场景。

wait()：使当前线程进入等待状态，并释放关联的互斥锁。当条件满足时，线程被唤醒并重新获取锁。
wakeOne()：唤醒一个正在等待的线程（按操作系统调度策略选择）。
wakeAll()：唤醒所有正在等待的线程。

常见用法

**线程等待条件：**线程检查条件，若不满足则调用wait()进入等待。
**条件通知：**另一线程修改条件后，调用wakeOne()或wakeAll()通知等待线程。
**配合QMutex：**所有条件检查和修改必须在QMutex保护下进行，避免竞态条件。

任务队列描述

**任务队列：**主线程将任务添加到队列，多个工作线程从队列中获取并执行任务。
**同步机制：**当队列为空时，工作线程等待；当新任务到达时，唤醒一个线程处理。
**优雅退出：**支持安全终止所有工作线程。

代码实现

#include <QCoreApplication>
#include <QThread>
#include <QMutex>
#include <QWaitCondition>
#include <QQueue>
#include <QDebug>
#include <functional>// 定义任务类型（使用std::function包装可调用对象）
using Task = std::function<void()>;// 线程安全的任务队列
class TaskQueue {
public:void addTask(const Task& task) {QMutexLocker locker(&m_mutex);m_queue.enqueue(task);m_cond.wakeOne(); // 唤醒一个等待线程}Task getTask() {QMutexLocker locker(&m_mutex);//离开作用域（即析构）时自动对m_mutex解锁// 使用while防止虚假唤醒while (m_queue.isEmpty() && !m_stop) {m_cond.wait(&m_mutex); // 自动释放锁并等待，被唤醒（即wait返回）之后自动对m_mutex重新上锁}if (m_stop) return nullptr; // 终止信号return m_queue.dequeue();}void stop() {QMutexLocker locker(&m_mutex);m_stop = true;m_cond.wakeAll(); // 唤醒所有线程退出}private:QMutex m_mutex;QWaitCondition m_cond;QQueue<Task> m_queue;bool m_stop = false;
};// 工作线程：不断从队列中取任务执行
class Worker : public QThread {
public:Worker(TaskQueue* queue) : m_queue(queue) {}void run() override {while (true) {Task task = m_queue->getTask();if (!task) break; // 收到终止信号task(); // 执行任务}qDebug() << "Worker thread" << QThread::currentThread() << "stopped.";}private:TaskQueue* m_queue;
};int main(int argc, char* argv[]) {QCoreApplication a(argc, argv);// 创建任务队列和4个工作线程TaskQueue queue;QList<Worker*> workers;for (int i = 0; i < 4; ++i) {Worker* worker = new Worker(&queue);worker->start();workers.append(worker);}// 添加10个任务到队列for (int i = 0; i < 10; ++i) {queue.addTask([i]() {qDebug() << "Task" << i << "processed by" << QThread::currentThread();QThread::msleep(100); // 模拟任务耗时});}// 等待所有任务执行完毕QThread::sleep(2);// 停止所有工作线程queue.stop();for (Worker* worker : workers) {worker->wait();delete worker;}qDebug() << "All workers stopped.";return 0;
}

运行代码输出

Task 0 processed by QThread(0x1087708)
Task 3 processed by QThread(0x10879d0)
Task 1 processed by QThread(0x10878d0)
Task 2 processed by QThread(0x1087800)
Task 4 processed by QThread(0x1087800)
Task 5 processed by QThread(0x10878d0)
Task 7 processed by QThread(0x10879d0)
Task 6 processed by QThread(0x1087708)
Task 8 processed by QThread(0x10878d0)
Task 9 processed by QThread(0x1087800)
Worker thread QThread(0x1087708) stopped.
Worker thread QThread(0x10879d0) stopped.
Worker thread QThread(0x1087800) stopped.
Worker thread QThread(0x10878d0) stopped.
All workers stopped.