跨线程发射信号后如何正确读取返回值？

在以下Qt多线程代码中，发射signalTest信号后，变量response输出0而非预期的999，下面分析问题原因并给出解决方案：

问题代码 #

Worker类定义 #

class Worker : public QObject {
    Q_OBJECT
public:
    
    Worker() 
    {
        connect(this, &Worker::signalTest, this, [this] (int x)
        {
            this->Test(x);
        });
    };

    int Test(int x)
    {
      qDebug() << "x: " << x;
      return 999;
    }

signals:
    int signalTest(int x);
};

主线程调用代码 #

QThread* thread = new QThread();
Worker* worker = new Worker();
worker->moveToThread(thread);

thread->start(); 

int response = emit worker->signalTest(10);
qDebug() << "response: " << response;

问题原因 #

当Worker对象被移到另一个线程后，信号与槽的连接类型默认变为队列连接（Qt::QueuedConnection）。这种模式下，信号的发射是异步的：发射信号的主线程不会等待槽函数在Worker线程执行完成，而是直接返回返回值类型的默认值（int类型就是0），因此无法获取到Test函数实际返回的999。

只有在同一线程内的直接连接（Qt::DirectConnection）模式下，发射信号时才会立即执行槽函数并返回正确结果，但跨线程场景下默认是队列连接，所以出现此问题。

解决方案 #

方案一：使用阻塞队列连接（同步获取结果） #

通过指定Qt::BlockingQueuedConnection连接类型，让发射信号的主线程阻塞，直到槽函数在Worker线程执行完成并返回结果。注意：不能在Worker线程内部发射该信号，否则会导致死锁。

修改后的代码：

Worker类

class Worker : public QObject {
    Q_OBJECT
public:
    Worker() = default; // 移除构造函数内的连接逻辑

    int Test(int x)
    {
      qDebug() << "x: " << x;
      return 999;
    }

signals:
    int signalTest(int x);
};

主线程代码

QThread* thread = new QThread();
Worker* worker = new Worker();
worker->moveToThread(thread);

// 指定阻塞队列连接类型
connect(worker, &Worker::signalTest, worker, &Worker::Test, Qt::BlockingQueuedConnection);

thread->start(); 

int response = emit worker->signalTest(10);
qDebug() << "response: " << response; // 此时输出999

// 记得清理线程资源
thread->quit();
thread->wait();
delete worker;
delete thread;

方案二：回调函数异步获取结果 #

如果不想阻塞主线程，可以通过传递回调函数的方式，让Worker执行完成后主动将结果返回给主线程。

修改后的代码：

Worker类

class Worker : public QObject {
    Q_OBJECT
public:
    Worker() = default;

    void TestWithCallback(int x, std::function<void(int)> callback)
    {
      qDebug() << "x: " << x;
      int result = 999;
      // 确保回调在主线程执行（如果回调涉及UI操作必须这么做）
      QMetaObject::invokeMethod(qApp, [callback, result](){
          callback(result);
      }, Qt::QueuedConnection);
    }
};

主线程代码

QThread* thread = new QThread();
Worker* worker = new Worker();
worker->moveToThread(thread);

thread->start(); 

// 异步调用，主线程不会被阻塞
QMetaObject::invokeMethod(worker, "TestWithCallback", Qt::QueuedConnection,
                          Q_ARG(int, 10),
                          Q_ARG(std::function<void(int)>, [](int result){
                              qDebug() << "response: " << result; // 输出999
                          }));

// 主线程可以继续执行其他任务...

// 清理资源
thread->quit();
thread->wait();
delete worker;
delete thread;

方案三：使用Qt Concurrent框架 #

利用Qt Concurrent的线程池功能，无需手动管理线程，通过QFuture获取返回值：

代码示例

#include <QtConcurrent/QtConcurrent>

class Worker : public QObject {
    Q_OBJECT
public:
    Worker() = default;

    int Test(int x)
    {
      qDebug() << "x: " << x;
      return 999;
    }
};

// 主线程代码
Worker* worker = new Worker();
// 将Test任务提交到线程池执行
QFuture<int> future = QtConcurrent::run(worker, &Worker::Test, 10);
// 同步等待结果（也可以用future.waitForFinished()异步等待）
int response = future.result();
qDebug() << "response: " << response; // 输出999

delete worker;

内容的提问来源于stack exchange，提问作者Cesar