QT开发中文网

在上述代码基础上,task任务等待500ms没处理完再丢入到线程中处理

如果你希望任务在等待一段时间后再被处理,可以使用QTimer来实现延迟。下面是修改后的示例代码:

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

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

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

public slots:
    void run() {
        // 执行任务逻辑
        qDebug() << "Running task...";
        // 模拟耗时操作
        QThread::msleep(2000);
        qDebug() << "Task completed.";
    }
};

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

public:
    WorkerThread(QObject* parent = nullptr) : QThread(parent), timer(new QTimer(this)) {
        connect(timer, &QTimer::timeout, this, &WorkerThread::processTasks);
    }

signals:
    void newTask();

protected:
    void run() override {
        timer->start(500); // 开启定时器,每500毫秒触发一次处理任务的槽函数
        exec(); // 进入事件循环,保持线程活动状态
    }

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

private slots:
    void processTasks() {
        if (!taskQueue.isEmpty()) {
            // 从任务队列中取出一个任务并执行
            Task* task = taskQueue.dequeue();
            task->run();
            delete task;
        }
    }

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

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();
}

在这个修改后的示例中,我们引入了一个QTimer定时器,并将其连接到工作线程的processTasks()槽函数上。每当定时器超时(500ms),即触发一次处理任务的操作。这样可以实现等待500ms后再将任务丢入线程中进行处理。

注意,在任务执行过程中,为了模拟耗时操作,我使用了QThread::msleep(2000)来让任务暂停2秒钟。你可以根据实际需求进行调整。

请确保遵循Qt多线程编程的相关规范和线程安全性原则,并根据具体情况进行适当的修改。


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

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://qt.0voice.com/?id=9233

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?