如果你希望任务在等待一段时间后再被处理,可以使用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助手提供,问题来源于学员提问