KcF*_*nMi 3 c++ qt multithreading qthread qtimer
QThread文档建议了两种使代码在单独的线程中运行的方法。如果我子类化 QThread 并重新实现 run(),那么我得到
QBasicTimer::start: Timers cannot be started from another thread
Run Code Online (Sandbox Code Playgroud)
-
#include <QWidget>
#include <QThread>
#include <QBasicTimer>
#include <QDebug>
#include <QEvent>
#include <QCoreApplication>
class Worker : public QThread
{
Q_OBJECT
int id;
bool m_abort = false;
bool compute = false;
public:
Worker() {}
protected:
void timerEvent(QTimerEvent *event) override {
if (event->timerId() == id) {
compute = true;
} else {
QObject::timerEvent(event);
}
}
public slots:
void abort() {m_abort = true;}
void run() {
qDebug() << QThread::currentThreadId();
QBasicTimer timer;
id = timer.timerId();
timer.start(1000, this);
forever {
if (m_abort) break;
QCoreApplication::processEvents();
if (compute)
qDebug() << "computed";
compute = false;
}
}
};
class MainWidget : public QWidget
{
Q_OBJECT
QThread thread;
Worker* worker;
public:
MainWidget()
{
qDebug() << QThread::currentThreadId();
worker = new Worker;
worker->start();
}
~MainWidget(){worker->abort();}
};
Run Code Online (Sandbox Code Playgroud)
1)计时器是否从另一个线程启动?
2)为什么当 QBasicTimer 被 QTimer 替换时我没有收到该警告?
3)为什么我在使用 moveToThread 时没有收到该警告?
#include <QWidget>
#include <QThread>
#include <QBasicTimer>
#include <QDebug>
#include <QEvent>
#include <QCoreApplication>
class Worker : public QObject
{
Q_OBJECT
QBasicTimer* timer;
bool m_abort = false;
bool compute = false;
public:
Worker() {}
protected:
void timerEvent(QTimerEvent *event) override {
if (event->timerId() == timer->timerId()) {
compute = true;
} else {
QObject::timerEvent(event);
}
}
public slots:
void abort() {m_abort = true;}
void run() {
timer = new QBasicTimer;
timer->start(1000, this);
forever {
if (m_abort) break;
QCoreApplication::processEvents();
if (compute)
qDebug() << "computed";
compute = false;
}
}
};
class MainWidget : public QWidget
{
Q_OBJECT
QThread thread;
Worker* worker;
public:
MainWidget()
{
worker = new Worker;
worker->moveToThread(&thread);
connect(this, &MainWidget::start, worker, &Worker::run);
thread.start();
emit start();
}
~MainWidget(){worker->abort(); thread.quit(); thread.wait();}
signals:
void start();
};
Run Code Online (Sandbox Code Playgroud)
关于第一个(非moveToThread)示例......
快速查看 Qt 源代码QBasicTimer::start显示以下内容......
void QBasicTimer::start(int msec, QObject *obj)
{
QAbstractEventDispatcher *eventDispatcher = QAbstractEventDispatcher::instance();
// ...
if (Q_UNLIKELY(obj && obj->thread() != eventDispatcher->thread())) {
qWarning("QBasicTimer::start: Timers cannot be started from another thread");
return;
}
Run Code Online (Sandbox Code Playgroud)
因此它期望第二个参数的obj线程关联性等于当前线程。
然而,在您的Worker::run实施中,您...
timer.start(1000, this);
Run Code Online (Sandbox Code Playgroud)
在此上下文中,当前线程是实例创建的新线程QThread,但this指的是主 GUI 线程上QWorker创建的实例。MainWidget因此发出警告。
编辑1:
对于这个问题...
为什么它与 moveToThread() 一起使用?
考虑ctor的实现MainWidget...
MainWidget()
{
worker = new Worker;
worker->moveToThread(&thread);
connect(this, &MainWidget::start, worker, &Worker::run);
thread.start();
emit start();
}
Run Code Online (Sandbox Code Playgroud)
Worker::run到调用时,Worker实例已移至新线程。那么当线路...
timer.start(1000, this);
Run Code Online (Sandbox Code Playgroud)
执行this(指的是实例Worker)在当前线程上,并且线程亲和性测试在QBasicTimer::start没有警告的情况下通过。
抱歉,如果上面的内容有点复杂,但重要的是要考虑第二个参数的线程关联性QBasicTimer::start:它必须是当前正在运行的线程。