QThread 使用同时新增任务队列-QT开发中文网

在Qt中，你可以使用QThread和任务队列结合的方式来实现同时新增任务的功能。下面是一个简单示例：

#include <QThread>
#include <QMutex>
#include <QQueue>
#include <QDebug>

// 定义任务类
class Task : public QObject {
    Q_OBJECT

public:
    Task(QObject* parent = nullptr) : QObject(parent) {}

public slots:
    void run() {
        // 执行任务逻辑
        qDebug() << "Running task...";
    }
};

// 定义工作线程类
class WorkerThread : public QThread {
    Q_OBJECT

public:
    WorkerThread(QObject* parent = nullptr) : QThread(parent) {}

signals:
    void newTask();

protected:
    void run() override {
        while (true) {
            // 获取任务队列锁
            queueMutex.lock();
            if (taskQueue.isEmpty()) {
                // 如果任务队列为空，则等待新任务信号
                queueMutex.unlock();
                emit newTask();
            } else {
                // 从任务队列中取出一个任务并执行
                Task* task = taskQueue.dequeue();
                queueMutex.unlock();
                task->run();
                delete task;
            }
        }
    }

public slots:
    void addTask(Task* task) {
        // 添加新任务到队列中
        QMutexLocker locker(&queueMutex);
        taskQueue.enqueue(task);
    }

private:
    QQueue<Task*> taskQueue;
    QMutex queueMutex;
};

int main(int argc, char** argv)
{
    QApplication app(argc, argv);

    // 创建工作线程和任务对象
    WorkerThread workerThread;
    
    for (int i = 0; i < 10; ++i) {
        Task* task = new Task();
        workerThread.addTask(task);
    }
    
    // 连接新任务信号和添加任务槽函数
    QObject::connect(&workerThread, &WorkerThread::newTask, [&workerThread]() {
        Task* task = new Task();
        workerThread.addTask(task);
    });
    
    // 启动工作线程
    workerThread.start();

    return app.exec();
}

在这个示例中，我们创建了一个WorkerThread类继承自QThread，负责执行任务。通过使用QQueue作为任务队列，并使用QMutex来保证对队列的线程安全访问。工作线程会不断地从任务队列中取出任务并执行，如果队列为空则等待新任务信号。

在主函数中，我们首先创建了一些初始任务，并连接了WorkerThread的newTask信号与添加新任务的槽函数。然后启动工作线程，它会自动开始处理任务。

当需要新增任务时，在任何地方调用workerThread.addTask()即可将新的Task对象添加到队列中。

这样就实现了同时新增任务到队列并由工作线程处理的功能。注意要遵循Qt多线程编程的相关规范和线程安全性原则。

内容由零声教学AI助手提供，问题来源于学员提问