QThread 在可以使用之前永远不会运行/完成？

Question

我创建了一个名为 EncodeThread 的自定义 QObject 类，如下所示：

class EncodeThread : public QObject {
    Q_OBJECT

public:
    void set(SWSL::Video* v, QStringList f, QDir vDir);
    void run();

public slots:
    void encode();

signals:
    void encodeProgress(int i);

private:
    SWSL::Video* video;
    QStringList files;
    QDir videoDir;
};

显而易见，该类用于使用外部库对视频进行编码。 Encode() 包含实际的编码例程，run() 是我在故障排除时添加的一个函数，尽管它显然不起作用：

void EncodeThread::run() {
    if (currentThread() != this) {
        // caller is in different thread.
        QMetaObject::invokeMethod(this, "encode", Qt::QueuedConnection);
    }
    else {
        encode();
    }
}

问题是当我在 EncodeThread 实例上使用 QThread 和 moveToThread() 函数时，即似乎什么也没有发生。不写入任何数据，并且实例永远不会发出应将编码文件保存到磁盘的信号。

encThread.set(video, files, videoDir);
connect(&encThread, SIGNAL(encodeProgress(int)), cookVideoProgress, SLOT(setValue(int)));
    connect(&encThread, SIGNAL(finished()), this, SLOT(videoCookEnd()));
    connect(this, SIGNAL(videoEncode()), &encThread, SLOT(encode()));
encThread.moveToThread(&thread);
    thread.start();

以上就是整个设置的启动方式。 EncThread 和线程变量在 MainWindow 类中声明。在尝试使用信号从主线程调用encode()并且QMetaObject失败后，我已经使EncodeThread的set()函数调用encode()。

我对线程并不陌生，曾经使用过本机 Windows 和 Linux 线程，以及各种跨平台实现的线程，但 QThreads 似乎确实让我感到困惑。任何建议都非常受欢迎:)

Answer 1

可能为时已晚，无法为您提供任何帮助，但这里有一个小演示程序，可以让 EncoderThread 类发挥作用。它可能与您的设计不太相符（您的问题只有片段），但它演示了在自己的线程上运行一个对象实例，并通过信号/槽在不同的线程上连接两个对象以使它们进行通信：

#include <stdio.h>
#include <QObject>
#include <QThread>
#include <QtCore/QCoreApplication>

// QSleeper is just a toy utility class that makes the
//  protected QThread::sleep() family of functions
//  publicly accessible.  It's only use is for demo
//  programs like this
class Sleeper : QThread
{
public:
    static void sleep(unsigned long secs) { QThread::sleep(secs); }
    static void msleep(unsigned long msecs) { QThread::msleep(msecs); }
    static void usleep(unsigned long usecs) { QThread::usleep(usecs); }

};


// an Encoder class that maintains itself on is own thread
class EncodeThread : public QObject {
    Q_OBJECT

public:
    EncodeThread();

public slots:
    void encode();

signals:
    void encodeProgress(int i);
    void finished();

private:
    QThread myThread;
};

EncodeThread::EncodeThread() {
    moveToThread(&myThread);
    myThread.start();
}


void EncodeThread::encode()
{
    printf("EncodeThread::encode() on thread %u\n", (unsigned int) QThread::currentThreadId());

    for (int i = 0; i < 6; ++i) {
        // encode for 1 second or so
        printf("EncodeThread::encode() working on thread %u\n", (unsigned int) QThread::currentThreadId());
        Sleeper::sleep(1);
        emit encodeProgress(i);
    }

    emit finished();
    printf("EncodeThread::encode() - done\n");
}




// a controller to manage and monitor an EncoderThread instance
class VideoEncoderController : public QObject
{
    Q_OBJECT
public:
    void start();

public slots:
    void setValue(int);
    void encodingDone();

signals:
    void encodingBegin();
};

void VideoEncoderController::start()
{
    printf("VideoEncoderController::start() on thread %u\n", (unsigned int) QThread::currentThreadId());
    emit encodingBegin();
}

void VideoEncoderController::setValue(int x)
{
    printf("VideoEncoderController::setValue(int %d) on thread %u\n", x, (unsigned int) QThread::currentThreadId());
}

void VideoEncoderController::encodingDone()
{
    printf("VideoEncoderController::encodingDone() on thread %u\n", (unsigned int) QThread::currentThreadId());
}




// a demo program that wires up a VideoEncoderController object to
//  an EncoderThread
int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    EncodeThread encThread;
    VideoEncoderController controller;

    QObject::connect(&encThread, SIGNAL(encodeProgress(int)), &controller, SLOT(setValue(int)));
    QObject::connect(&encThread, SIGNAL(finished()), &controller, SLOT(encodingDone()));
    QObject::connect(&controller, SIGNAL(encodingBegin()), &encThread, SLOT(encode()));

    printf("hello world on thread %u\n", (unsigned int) QThread::currentThreadId ());

    controller.start();

    return a.exec();
}



#include "main.moc"

Answer 2

您必须派生QThread，而不是QObject。 run()方法是QThread的抽象方法。

Answer 3

对于未来的程序员，我添加这个答案。 Qt 中通常有 3 种多线程方法。 低级别, 重用（让说中级） 和 高级别。

低级别还包括两种不同的方法。在低级别中，您可以继承 QThread 类并提供要在 void QThread::run() 覆盖；。在驱动类上调用 QThread::start() 后，run 中的代码将执行。

Qt 中低级多线程的另一种方法是中继 Qt 的事件循环。通过这种方式，您可以创建一个由 QObject 驱动的类，而不一定是由 QThread 驱动，然后使用 QThread 中。 href="https://doc.qt.io/qt-5/qobject.html#moveToThread" rel="nofollow noreferrer">这个。之后，您将在该 QThread 对象上调用 start() （此 QThread 对象是 QThread 类型的对象。您没有在这里创建 QThread 子类。我认为这是您在代码中误解的地方。

在 QThread 对象上调用 start() 后，其事件循环将在另一个线程中启动，并从代码中连接到 QObject 只要您不使用 Qt::DirectConnection 作为 这个。

这两种方法各有优点和缺点。当子类化 QThread 并使用 Qthread::run() 时，如果 run 中的代码在 while(true ) 循环中，处理器的线程之一将始终被 Qthread::run() 代码占用，而不是在程序中其他线程的线程池中。

QObject::moveToThread() 方法对于大多数情况都很有用。但是，如果 QObject 驱动类的槽将被非常频繁地调用，例如每秒 100 或 1000 次，则由于可能传递给槽的参数，内存使用量会增加，并且其中一些信号可能永远不会被调用。到达插槽。