2

Для теста, я начал реализовывать самый примитивный 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();
}
9
  • 2
    Так это. А QApplication, на который оно жалуется, есть? 13 янв 2021 в 19:18
  • @BeardedBeaver, нет, но он и не нужен. Он предназначен для GUI.
    – bbdd
    13 янв 2021 в 19:22
  • 2
    Ну вам сообщение об ошибке недвусмысленно намекает на то, что нужен цикл обработки событий, для которого нужен QApplication (на самом деле достаточно QCoreApplication емнип) 13 янв 2021 в 19:25
  • @BeardedBeaver, спасибо большое - помогло. Я честно говоря, забыл про его существование. Но при запуске программы, я все же не получаю сообщение от сигнала MyTask::started
    – bbdd
    13 янв 2021 в 19:35
  • 2
    @bbdd QThread::sleep() замени на QTimer::singleShot() пока QEventLoop не запустится сигналы из потока не будут приходить... а ещё мне emit в лямбде не нравится...
    – Fat-Zer
    15 янв 2021 в 0:13

1 ответ 1

3
+50

Вам следует разобраться с тем как в Qt работают сигналы и слоты. Я писал когда-то статью "правильная работа с потоками в Qt" на Хабре, Вы ее легко найдете поиском.

Если говорить коротко, то для корректной работы многих сигналов и слотов Вам нужен запущенный event loop. Идея в том что когда у Вас два потока пытаются посылать сигналы друг другу, то чтобы это работало в реальности каждый из них поддерживает специальную очередь для сообщений и крутит цикл который регулярно проверяет появление в этой очереди сообщений. Это и есть event loop. Он по умолчанию создается у каждого QThread, но есть и еще один специальный event loop для всего приложения. Там живут обработчики все QObject у которых нет явно назначенного отдельного QThread (в том числе сами объекты QThread) и там обрабатываются сообщения от операционной системы. Например если Вы попытаетесь закрыть программу до того как она завершится сама, то это событие будет обработано именно там. И когда Ваши два потока завершатся, то именно этот цикл должен будет решить что пора завершать программу самостоятельно. Вот эти все connect между Worker::stopped и Worker::deleteLater - все это обрабатывается там.

Для запуска этого системного event loop (ну и подобных технических вещей) в Qt есть специальный класс QApplication и его специализации. Вам нужен, как уже заметили, минималистический QCoreApplication. А собственно запуск цикла у этого класса - это вызов функции .exec(). Который у Вас происходит после того как Вы попытались запустить event loop в QThread. Вполне закономерно что Вы получаете сообщения об ошибках - первый поток стартует еще до того как запустился системный event loop.

Как это поправить? Один из способов - запускать Ваши потоки не явным вызовом .start() а через отправку события. Эта функция не просто так сделана слотом. Последовательность действий должна быть такова:

  1. Вы создаете QApplication (всегда это должно быть одно из первых действий программы до создания любых QObject). Это создает в числе прочего системный event loop и позволяет помещать туда события
  2. Создаете свой начальный набор событий, потоков и т.п. Отправляете им событие "запустись". Оно будет помещено в очередь QApplication но реально не отправлено, т.к. event loop еще не запущен
  3. Зовете app.exec(). Event loop запускается и рассылает Ваши сообщения получателям, у Вас запускаются потоки и все работает

Но вообще исходя из Вашей задачи, мне кажется что Вам стоит присмотреться к QConcurrent. Грубо говоря вызывать QtConcurrent::run. Как вариант - использовать QThreadPool + QRunnable. Без использования QObject, сигналов и слотов. Тогда Вам будет не нужно QApplication и логика в целом скорее всего сильно упростится.

3
  • 1
    Большое спасибо за хороший ответ. Я прочитал Вашу статью, и вынес много полезного. Но у меня появился вопрос, связанный с созданием класса, унаследованного от QRunnable. Если я хочу избавиться от Worker-a и реализовать всю логику в одном классе, то при унаследовании QRunnable, я должен реализовать run метод. Окей, не проблема. Но могу ли я в методе start, запустить метод run в новом треде, благодаря QThreadPool, а именно: QThreadPool::globalInstance()->start(this);
    – bbdd
    16 янв 2021 в 18:19
  • Да, вполне можете. ->start() запустит Ваш код в отдельном потоке. Обратите только внимание что по умолчанию ->start() берет на себя владение переданным ему QRunnable и попытается в конце его самостоятельно удалить. Соответственно либо убедитесь что Ваш объект не попытается удалить кто-то другой (в частности не создавайте его на стеке) либо сделайте ему setAutoDelete(false) до start() 17 янв 2021 в 9:53
  • setAutoDelete(false) больше по душе. Большое спасибо за помощь.
    – bbdd
    17 янв 2021 в 11:03

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.