Qt C++：无需QConcurrent，如何结合信号使用QFutures（类Promise/Observable）？

我来帮你解决这个问题——在Qt的非阻塞事件驱动代码里，用信号触发Future兑现结果，核心是借助QPromise手动控制QFuture的状态，下面是具体实现方案和代码示例：

在Qt生态中，要实现“基于信号兑现Promise”的需求，QPromise是关键工具——它能让我们手动控制QFuture的完成状态，当frameReady信号触发时，通过QPromise设置结果，让对应的QFuture标记为完成。

核心代码实现 #

首先修改startTask的返回类型为QFuture<QByteArray>，然后用QPromise关联信号与结果：

#include <QFuture>
#include <QPromise>
#include <memory>
#include <stdexcept>

QFuture<QByteArray> RfidCardReader::startTask(QByteArray send) {
    if (!this->busy) {
        this->busy = true; // 标记为忙碌，避免并发任务冲突
        // 用shared_ptr持有promise，确保lambda触发时对象仍有效
        auto promise = std::make_shared<QPromise<QByteArray>>();
        QFuture<QByteArray> future = promise->future();

        // 用单次连接确保信号只触发一次，避免重复设置promise结果（会导致未定义行为）
        connect(this, &RfidCardReader::frameReady, this, [this, promise]() {
            // 给promise设置结果，完成Future
            promise->set_result(this->int_read_buffer);
            this->busy = false; // 任务完成，重置忙碌状态
        }, Qt::SingleShotConnection);

        this->sendFrame(send);
        return future;
    } else {
        // 忙碌时返回带异常的Future，调用方可以捕获错误
        QPromise<QByteArray> promise;
        promise.set_exception(std::make_exception_ptr(std::runtime_error("Reader is currently busy")));
        return promise.future();
    }
}

关键细节解释 #

• QPromise生命周期管理：用std::shared_ptr持有QPromise，因为startTask执行完毕后栈上的QPromise会被销毁，而信号可能在之后才触发，shared_ptr能保证对象在lambda执行时仍然有效。
• 单次连接机制：使用Qt::SingleShotConnection确保frameReady信号只触发一次lambda，避免多次调用set_result（这会导致未定义行为）。
• 异步错误处理：不再直接throw，而是通过promise.set_exception传递错误——因为startTask是异步返回的，直接throw无法被调用方捕获，通过Future传递异常更符合异步逻辑。
• 状态重置：在信号触发后重置busy状态，允许后续任务正常进入。

调用方如何处理Future #

你可以用QFutureWatcher监听Future的完成事件，实现非阻塞的结果处理：

// 调用startTask获取异步Future
auto readFuture = rfidReader->startTask(sendData);

// 创建Watcher监听完成事件
QFutureWatcher<QByteArray>* watcher = new QFutureWatcher<QByteArray>();
connect(watcher, &QFutureWatcher<QByteArray>::finished, [watcher]() {
    try {
        QByteArray result = watcher->future().result();
        // 处理读取到的RFID数据
        qDebug() << "Received RFID data:" << result;
    } catch (const std::exception& e) {
        // 处理错误情况
        qDebug() << "Task failed:" << e.what();
    }
    watcher->deleteLater(); // 记得清理Watcher对象
});
watcher->setFuture(readFuture);

额外优化建议 #

• 如果sendFrame可能失败（比如硬件连接错误），建议额外连接错误信号，在错误发生时调用promise->set_exception，确保Future能正确传递错误状态。
• 如果需要支持任务排队，可以把等待的QPromise加入一个队列，当前任务完成后自动启动下一个任务。

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