Для теста, я начал реализовывать самый примитивный worker
, который будет помещен в QThread
, и тут же столкнулся с проблемой, а именно с данной ошибкой:
QEventLoop: Cannot be used without QApplication
Я хочу реализовать самый простой способ запуска потока с помощью worker-а
. Код выглядит так:
worker.h
class Worker : public QObject
{
Q_OBJECT
public:
explicit Worker(QObject* parrent = nullptr);
Worker &operator=(const Worker &other) = delete;
Worker &operator=(Worker &&other) = delete;
Worker(const Worker &other) = delete;
Worker(Worker &&other) = delete;
virtual ~Worker() = default;
public slots:
virtual void start();
virtual void stop ();
signals:
void started();
void stopped();
};
worker.cpp
Worker::Worker(QObject* parrent) : QObject(parrent)
{
}
void Worker::start()
{
qDebug() << "Worker started";
emit started();
}
void Worker::stop ()
{
qDebug() << "Worker stopped";
emit stopped();
}
mytask.h
class MyTask : public QObject
{
Q_OBJECT
public:
explicit MyTask(QObject* parrent = nullptr);
MyTask& operator=(const MyTask& other) = delete;
MyTask& operator=(MyTask&& other) = delete;
MyTask(const MyTask& other) = delete;
MyTask(MyTask&& other) = delete;
virtual ~MyTask() = default;
virtual void start();
virtual void stop ();
signals:
void started();
void stopped();
protected:
Worker* p_worker{ nullptr };
};
mytask.cpp
MyTask::MyTask(QObject* parrent) : QObject(parrent), p_worker(nullptr)
{
}
void MyTask::stop()
{
if (p_worker) {
p_worker->stop();
}
}
void MyTask::start()
{
p_worker = new Worker();
QThread* thread = new QThread();
p_worker->moveToThread(thread);
connect(this, &MyTask::started, this, [](){qDebug() << "MyTask started";});
connect(this, &MyTask::stopped, this, [](){qDebug() << "MyTask stopped";});
connect(thread, &QThread::started, p_worker, &Worker::start, Qt::DirectConnection);
connect(p_worker, &Worker::started, this, [this](){emit started();}, Qt::DirectConnection);
connect(p_worker, &Worker::stopped, this, [this](){emit stopped();}, Qt::DirectConnection);
connect(p_worker, &Worker::stopped, thread, &QThread::quit, Qt::DirectConnection);
connect(p_worker, &Worker::stopped, p_worker, &Worker::deleteLater, Qt::DirectConnection);
connect(thread, &QThread::finished, thread, &QThread::deleteLater, Qt::DirectConnection);
thread->start();
}
Важно отметить то, что мне нужна реализация именно с использованием worker-a
. При создании worker-a
, я буду работать с ним при помощи сигналов. Стоит также отметить, что в этом примере все проверки на устранение повторного запуска потока и так далее игнорируются (для демонстрации упращеного кода).
Данный пример должен был бы вывести мне в качестве результата вот такое последование сообщений:
Worker started
MyTask started
Worker stopped
MyTask stopped
но я получаю:
Worker started
QEventLoop: Cannot be used without QApplication
Worker stopped
MyTask stopped
UPD Код запуска программы:
int main(int argc, char **argv)
{
QCoreApplication a(argc, argv);
MyTask task;
task.start();
QThread::sleep(1);
task.stop();
QThread::sleep(1);
return a.exec();
}
QApplication
, на который оно жалуется, есть?QApplication
(на самом деле достаточноQCoreApplication
емнип)MyTask::started
QThread::sleep()
замени наQTimer::singleShot()
покаQEventLoop
не запустится сигналы из потока не будут приходить... а ещё мнеemit
в лямбде не нравится...