Вызов методов в контексте QThread

Question

В моем приложении есть основной поток и рабочий поток (QThread).
Из основного потока я бы хотел вызвать метод моего рабочего потока и запустить его в контексте потока.

Я пытался использовать QMetaObject::invokeMethod и дать ему QueuedConnection вариант, но он не работает.
Я также попытался передать сигналы из основного потока (который подключен к слоту рабочего потока), но это также не удалось.

Вот фрагмент примерно того, что я пробовал:

class Worker : public QThread
{
    Q_OBJECT

public:
    Worker() { }

    void run() 
    { 
        qDebug() << "new thread id " << QThread::currentThreadId(); 
        exec(); 
    }

public slots:
    void doWork()
    {
        qDebug() << "executing thread id - " << QThread::currentThreadId();
    }
};

Используя способ QMetaObject:

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    qDebug() << "main thread id - " << QThread::currentThreadId();

    Worker worker;
    worker.start();

    QMetaObject::invokeMethod(&worker, "doWork", Qt::QueuedConnection);

    return a.exec();
}

Используя сигнальный путь:

class Dummy : public QObject
{
    Q_OBJECT

public:
    Dummy() { }

public slots:
    void askWork() { emit work(); }

signals:
    void work();
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    qDebug() << "main thread id - " << QThread::currentThreadId();

    Worker worker;
    worker.start();

    Dummy dummy;
    QObject::connect(&dummy, SIGNAL(work()), &worker, SLOT(doWork()), Qt::QueuedConnection);

    QTimer::singleShot(1000, &dummy, SLOT(askWork()));

    return a.exec();
}

Оба способа приводят к тому, что идентификатор основного потока печатается в QThreaddoWork,

Кроме того, я думал о реализации простого производителя-потребителя, но если это работает, есть ли причина, почему бы не сделать это таким образом?

Answer 1

Проблема заключалась в том, что получатель (QThread) "живет" в основном потоке, и, таким образом, цикл событий основного потока является тем, который выполняет слот.

из документации Qt:

При подключениях в очереди слот вызывается, когда управление возвращается в цикл обработки событий потока, которому принадлежит объект. Слот выполняется в потоке, в котором находится объект-получатель.

Таким образом, решение, которое я нашел до сих пор, состояло в том, чтобы создать объект внутри run() потока и использовать вместо него его слоты. Таким образом, владельцем получателя является поток, а затем слот вызывается в контексте потоков.

Answer 2

Для простого примера производителя-потребителя, посмотрите на запись в блоге от Брэдли Т. Хьюз Трединг без головной боли.

Answer 3

В этом примере показано, как можно разделить класс Worker, чтобы он работал так, как вы хотите. Вам также необходимо сделать ссылку или указатель на экземпляр Worker, чтобы иметь возможность подключиться к слоту.

class Worker : public QObject
{
    Q_OBJECT

public:
    Worker() { }

public slots:
    void doWork()
    {
        qDebug() << "executing thread id - " << QThread::currentThreadId();
    }
};

class WorkerThread : public QThread
{
    Q_OBJECT

public:
    void run()
    {
        qDebug() << "new thread id " << QThread::currentThreadId(); 
        Worker worker;
        exec();
    }
};

Answer 4

Рабочий создается в основном потоке, и поэтому его события обрабатываются в основном потоке. Вы должны переместить Worker в его собственный поток:

Worker worker;
worker.moveToThread(&worker);
worker.start();

Теперь Qt знает worker живет в новом потоке и будет помещать в очередь события в этом цикле событий.

Answer 5

Похоже, ваш рабочий поток завершает работу еще до того, как вы сможете вызвать какую-либо функцию или отправить ей сигнал.