QT中子线程触发主线程弹窗并阻塞等待用户响应-传统信号槽实现

news2025/6/3 23:33:56

QT中子线程触发主线程弹窗并阻塞等待用户响应

传统信号槽实现

场景需求：在子线程执行耗时任务时，需暂停并触发主线程弹窗获取用户决策，子线程需阻塞等待响应后继续执行或终止。

实现思路

异步任务触发条件：在子线程的异步计算中，当满足特定条件时，通过信号通知主线程弹出QMessageBox。
主线程弹窗：主线程接收信号后弹出对话框，并根据用户选择发送响应信号。
子线程阻塞等待：子线程使用QEventLoop或QWaitCondition阻塞，直到主线程返回用户的选择结果。

具体步骤

1. 定义信号与槽

子线程到主线程的信号：用于触发弹窗请求，并传递条件相关的信息。
主线程到子线程的信号：用于返回用户的选择结果（继续或取消）。

// 主线程类（如MainWindow）
class MainWindow : public QMainWindow {
    Q_OBJECT
public:
    // 接收子线程的弹窗请求
    void onAskUser(const QString& message);

signals:
    // 主线程发送用户选择的信号
    void userResponseReceived(bool continueRunning);

private slots:
    // 处理弹窗逻辑
    void handleUserRequest(const QString& message);
};

// 子线程任务类
class AsyncTask : public QObject {
    Q_OBJECT
public:
    void runTask();

signals:
    // 子线程请求弹窗
    void askUser(const QString& message);
    // 任务完成或终止
    void taskFinished();

public slots:
    // 接收用户选择结果
    void onUserResponse(bool continueRunning);
};

2. 异步任务中触发弹窗

在子线程的异步计算中，当需要弹窗时，通过信号通知主线程，并使用QEventLoop阻塞等待响应：

void AsyncTask::runTask() {
    QFutureWatcher<void> watcher;
    QFuture<void> future = QtConcurrent::run([this]() {
        // 模拟异步计算
        for (int i = 0; i < 100; ++i) {
            if (i == 50) { // 触发条件
                emit askUser("是否继续执行？");
                QEventLoop loop;
                connect(this, &AsyncTask::userResponseReceived, &loop, &QEventLoop::quit);
                loop.exec(); // 阻塞等待用户响应
                if (!m_continueRunning) break;
            }
            // 继续计算...
        }
        emit taskFinished();
    });
    watcher.setFuture(future);
}

3. 主线程处理弹窗

主线程接收弹窗请求后弹出QMessageBox，并通过信号返回用户选择：

void MainWindow::handleUserRequest(const QString& message) {
    QMessageBox::StandardButton reply = QMessageBox::question(
        this, "确认", message, QMessageBox::Yes | QMessageBox::No
    );
    emit userResponseReceived(reply == QMessageBox::Yes);
}

4. 连接信号与槽

使用Qt::BlockingQueuedConnection确保子线程阻塞等待主线程响应：

// 主线程中连接信号
AsyncTask* task = new AsyncTask;
connect(task, &AsyncTask::askUser, this, &MainWindow::handleUserRequest, Qt::BlockingQueuedConnection);
connect(this, &MainWindow::userResponseReceived, task, &AsyncTask::onUserResponse);

关键点

线程间通信：
- 使用Qt::BlockingQueuedConnection连接信号槽，使子线程在发出信号后阻塞，直到主线程处理完毕。
- 主线程通过QMessageBox获取用户输入，并返回结果给子线程。
避免界面冻结：
- 子线程通过QEventLoop局部事件循环实现阻塞，而非直接调用QMessageBox，防止主线程卡死。
资源管理：
- 使用QFutureWatcher监控异步任务状态，确保任务完成后释放资源。